Нужна помощь в беге flask с сельдереем - PullRequest
Новая
       59

Нужна помощь в беге flask с сельдереем

0 голосов
/ 17 января 2020

привет, нужна помощь по запуску flask сельдерея с сельдереем, который побежал в моих работах с сельдереем с помощью make worker, но я не могу видеть, как работает сельдерей 

  BROKER_URL = "amqp://guest:guest@localhost/"
    CELERY_RESULT_BACKEND = "amqp://guest:guest@localhost/"
    CELERY_TASK_SERIALIZER = "json"
    CELERYBEAT_SCHEDULE = {
     'scheduled_broadcast': {
        'task':'tasks.send',
        'schedule': crontab(minute=1),
        'args':()
    },
    'add-every-30-seconds': {
        'task': 'tasks.post',
        'schedule': 30.0,
        'args': (16, 16)
      },
   }

, затем в файле задачи 

 @celery.task
   def send():
    print("Hello , ")
    logger.info('Hello')

   @celery.post(name='tasks.add')
   def hello():
    app.logger.info('run my function')
...