>
> Hi!
>
> I'm trying to create a chat that when it meets the condition of "hola" is
> sent by a task in celery. However, when it enters the condition the status
> is not updated, can someone help me?
>
>
> I leave my code, please help me!
>
>
> Please help me, thx! And sorry for my english :s
>
And the error is
[2018-04-18 01:11:25,798: WARNING/MainProcess]
c:\python\lib\site-packages\celery\concurrency\base.py:31: RuntimeWarning:
coroutine 'MensajeAlGrupo' was never awaited
ret = target(*args, **kwargs)
>
> *consumers.py*
>
> import jsonfrom channels.generic.websocket import
> AsyncWebsocketConsumerfrom .tasks import MensajeAlGrupo
> class Consumidor(AsyncWebsocketConsumer):
> async def connect(self):
> # Join room group
> await self.channel_layer.group_add(
> 'grupo',
> self.channel_name
> )
> await self.accept()
>
> async def disconnect(self, close_code):
> await self.channel_layer.group_discard(
> 'grupo',
> self.channel_name
> )
>
> # Receive message from WebSocket
> async def receive(self, text_data):
> text_data_json = json.loads(text_data)
> message = text_data_json['message']
> if str(message) == "hola":
> MensajeAlGrupo.delay()
> else:
>
> # Send message to room group
> await self.channel_layer.group_send(
> 'grupo',
> {
> 'type': 'chat_message',
> 'message': message
> }
> )
>
> # Receive message from room group
> async def chat_message(self, event):
> message = event['message']
>
> # Send message to WebSocket
> await self.send(text_data=json.dumps({
> 'message': message
> }))
>
>
> *tasks.py*
>
> #De celeryfrom Filtros.celery import appfrom channels.layers import
> get_channel_layer
>
> @app.task()
> async def MensajeAlGrupo():
> channel_layer = get_channel_layer()
> await channel_layer.group_send(
> 'grupo',
> {"type": "chat_message", "message": "Hello World"},
> )
>
>
>
> *celery.py*
>
> #De celeryfrom __future__ import absolute_import, unicode_literalsimport
> osfrom celery import Celery
> # set the default Django settings module for the 'celery' program.
> os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'Filtros.settings')
>
> app = Celery('Proyecto')
> app.config_from_object('django.conf:settings', namespace='CELERY')
> app.autodiscover_tasks()
>
> app.conf.update(
> BROKER_URL = 'redis://127.0.0.1:6379/0',)
>
>
--
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 [email protected].
To post to this group, send email to [email protected].
Visit this group at https://groups.google.com/group/django-users.
To view this discussion on the web visit
https://groups.google.com/d/msgid/django-users/a4da7470-a707-49c0-878d-27b4a9b3c0a0%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
