Hello guys!
I'm stucked on this problem, i have some script to save data to database using a django object.
The script is with async,so i have to use the 'sync_to_async' function.
Beyond that, running the script raise the ASynchronous exception, but it's look correct.
Code:
```
async def cycle_send_to_dj(self, *args):
"""
Leer la cola que recibe de rmq
Enviar cada dato recibido de la cola y cargarlo
"""
queue = args[0]
data = []
try:
#breakpoint()
async for elem in read_async_queue(queue):
gprint("Recibiendo data en async queue")
rprint(elem)
# transformar elem para que sea guardable
try:
data_log = await statusdata2log(
elem.get("station"), **elem.get("data"))
if data_log:
try:
bprint("="*20+">")
gprint("Data log::::")
rprint(data_log)
bprint("ready to build")
breakpoint()
value = await sync_to_async(LogUnidadGNSS)(**data_log)
rprint(value)
data.append(value)
except Exception as e:
bprint("Creando lista de logs, error %s, LogUnidadGNSS create" % e)
raise e
except Exception as e:
print("Error al transformar elem %s" % e)
gprint("Data to save")
[print(elem) for elem in data]
if data:
#await dbaccess(LogUnidadGNSS.objects.bulk_create)(data)
await dbaccess(LogUnidadGNSS.objects.bulk_create)(data)
except Exception as e:
print("Hubo una excepción al guardar los datos de LogGNSS")
raise e
return args
```
I'm worng in somethinkg?