Как вызвать асинхронную функцию внутри задачи сельдерея - PullRequest
Новая
       18

Как вызвать асинхронную функцию внутри задачи сельдерея

0 голосов
/ 12 мая 2019

У меня есть веб-чат с использованием веб-сокетов (AsyncWebsocketConsumer, django-channel).Я использую сельдерей для разбора запроса, но он останавливается без ошибок, которые можно исправить (для меня) каждый раз, когда я пытаюсь отправить ответ потребителю.

Эта попытка выдает мне следующую ошибку: 

@shared_task
def execute(command, parameter, room_group_name):
    if command == '/stock':
        loop = asyncio.get_event_loop()
        loop.run_until_complete(sendData(stock(parameter), "BOT", room_group_name))
        return True
    loop = asyncio.get_event_loop()
    loop.run_until_complete(sendData("I do not understand that parameter", "BOT", room_group_name))
    return True


from channels.layers import get_channel_layer

async def sendData(message, from_, room_group_name):
    channel_layer = get_channel_layer()
    import datetime
    currentDT = datetime.datetime.now()
    datetime = currentDT.strftime("%Y-%m-%d %H:%M:%S")
    await channel_layer.group_send(
        room_group_name,
        {
            'type': 'chat_message',
            'username': from_,
            'datetime': datetime,
            'message': message
        }
    )
    await asyncio.sleep(5)

Ошибка: 

[2019-05-12 18:01:15,491: ERROR/ForkPoolWorker-1] Task chat.tasks.execute[8a69afca-8173-46d0-84bc-4ee5ce7782ca] raised unexpected: OSError(9, 'Bad file descriptor')
Traceback (most recent call last):
  File "/Users/juan/Documents/manu/dev/python_challenge/venv/lib/python3.6/site-packages/celery/app/trace.py", line 385, in trace_task
    R = retval = fun(*args, **kwargs)
  File "/Users/juan/Documents/manu/dev/python_challenge/venv/lib/python3.6/site-packages/celery/app/trace.py", line 648, in __protected_call__
    return self.run(*args, **kwargs)
  File "/Users/juan/Documents/manu/dev/python_challenge/chat/tasks.py", line 14, in execute
    loop.run_until_complete(sendData(stock(parameter), "BOT", room_group_name))
  File "/usr/local/Cellar/python/3.6.5/Frameworks/Python.framework/Versions/3.6/lib/python3.6/asyncio/base_events.py", line 455, in run_until_complete
    self.run_forever()
  File "/usr/local/Cellar/python/3.6.5/Frameworks/Python.framework/Versions/3.6/lib/python3.6/asyncio/base_events.py", line 422, in run_forever
    self._run_once()
  File "/usr/local/Cellar/python/3.6.5/Frameworks/Python.framework/Versions/3.6/lib/python3.6/asyncio/base_events.py", line 1396, in _run_once
    event_list = self._selector.select(timeout)
  File "/usr/local/Cellar/python/3.6.5/Frameworks/Python.framework/Versions/3.6/lib/python3.6/selectors.py", line 577, in select
    kev_list = self._kqueue.control(None, max_ev, timeout)
OSError: [Errno 9] Bad file descriptor

OSError: [Errno 9] Неверный дескриптор файла, но я не могу найти егоидет от.

сельдерей == 4.3.0

...