Stocker les transaction non transmises au sde
Suite à une erreur de manip, le token n'était plus bon pendant deux jours. La synchronisation de l'historique n'a pas été faite. Pour éviter que cela se reproduise, il faut stocker les transaction non transmises puis les transmettre quand tout est rentré dans l'ordre.
Ces lignes sont à améliorer.
if type_.endswith('-delete'):
async with aiohttp.ClientSession() as session:
async with session.delete(settings.WEB_URL + type_[:-7],
data=json.dumps(parsed_item),
proxy=proxy) as req:
if req.status != 200:
raise QueueProcessingException(req.status)
else:
async with aiohttp.ClientSession() as session:
async with session.put(settings.WEB_URL + type_,
data=json.dumps(parsed_item),
proxy=proxy) as req:
if req.status != 200:
raise QueueProcessingException(req.status)
Si il y a une erreur, i.e. req.status != 200
, stocker la transaction pour plus tard.