python - 向所有 worker 广播任务 : redis+celery

Question

任务.py

    from celery import Celery

app = Celery('tasks',
             broker='redis://localhost',
             backend='redis://localhost',
             include=['tasks'])

app.conf.broker_url = 'redis://localhost:6379/0'
# Optional configuration, see the application user guide.
app.conf.update(
    result_expires=3600,
)
@app.task
def add(x, y):
    return x + y

主要.py

from tasks import add


    if __name__ == '__main__':
        from celery import Celery
        app = Celery('tasks', backend='redis://localhost', broker='redis:localhost//')
        result = add.delay(4, 4)
        result.ready()
        value = result.get(timeout=10)
        print(value)

我想用 redis(broker 和后端)和 celery 向所有 worker 广播任务，但我没有实现，你能帮我吗？

Answer 1

例如:

import tasks
if __name__ == '__main__':
    tasks.app.do_something.apply_async(['222'], queue='broadcast_tasks')