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?
--
You received this message because you are subscribed to the Google Groups
"Django users" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to django-users+unsubscr...@googlegroups.com.
To view this discussion on the web visit
https://groups.google.com/d/msgid/django-users/70ef401a-636d-4464-a912-a3f004e2de3a%40googlegroups.com.
