сельдерей. Задержка зависает для этой задачи, но работает для других - PullRequest
Новая
       70

сельдерей. Задержка зависает для этой задачи, но работает для других

1 голос
/ 27 апреля 2020

Я пытаюсь отправлять уведомления с помощью сельдерея. 

@shared_task(name='send_notifis')
def send_notifs(device_ids, title, message):
    from pills_reminder.models import UserNotifications, UserDevice
    devices = UserDevice.objects.filter(id__in=device_ids)
    print(devices)
    device_tokens = []
    for device in devices:
        UserNotifications.objects.create(
            uid=device.device_id,
            title=title,
            message=message,
        )
        print(UserNotifications)
        device_tokens.append(device.registration_token)

    if len(device_tokens) > 1:
        device_tokens = ["".join(token.split()) for token in device_tokens]
        response = push_service.notify_multiple_devices(registration_ids=device_tokens,
                                             message_title=title,
                                             message_body=message)
    elif len(device_tokens) == 1:
        registration_id = "".join(device_tokens[0].split())
        response = push_service.notify_single_device(registration_id=registration_id,
                                          message_title=title,
                                          message_body=message)
    else:
        pass
    print(response)
    return True

это работает без .delay () и при работе с использованием python manage.py shell

>>> send_notifs.delay(devices, title='title', message='message')
<AsyncResult: f54188f8-cec6-42dd-a840-b097abffd7f4>

, но останавливается при вызове с использованием Django Модель post_save сигнал. 

@receiver(post_save, sender=Notification)
def Notification_post_save_handler(sender, instance, **kwargs):
    print('hello from post_save signal')
    devices = instance.get_devices()
    # send_notifs(devices)
    if len(devices)>0:
        send_notifs.delay(devices,
                    title=instance.title,
                    message=instance.message)

Приведенный выше код останавливает выполнение, но без .delay. все работает нормально.

UPADATE: 1

вышеуказанная задача с .delay выполняется с python manage.py shell, а не с runserver. так что проблема с сельдереем и Django настройками. Следовательно, я копаю глубоко и обнаружил

во время бега с shell я получаю, 

>>> add.app.conf #(add is a async task here)
{'broker_url': 'redis://localhost:6379/1'}, ...

, но бег с runserver дает: 

`{'broker_url': None}`

Теперь я ищу, как правильно установить настройки? Я использую django -конфигурации с celery.py как 

from __future__ import absolute_import, unicode_literals

import os

from celery import Celery

# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'core.settings')
os.environ.setdefault('DJANGO_CONFIGURATION', 'Development')

import configurations
configurations.setup()

app = Celery('core')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()


@app.task(bind=True)
def debug_task(self):
    print('Request: {0!r}'.format(self.request))

Любая помощь приветствуется. Спасибо за ваше время и терпение.

1 Ответ

1 голос
/ 01 мая 2020

используйте это 

from configurations import importer
importer.install()

вместо 

import configurations
configurations.setup()
...