如何使用celery任务创建单个文件可执行文件

2019年7月28日 160次阅读

我已经成功学习了Celery的一些基础知识,但我发现没有简单的方法来创建单个文件可执行文件(不需要运行celerybeat作为单独的进程来运行定期任务).可以编写应用程序并启动其工作进程(
http://docs.celeryproject.org/en/3.1/userguide/application.html)：

from datetime import timedelta
from celery import Celery
app = Celery()

@app.task
def test():
    print("he-he")

app.conf.update(
    BROKER_URL="redis://localhost:6379",
    CELERY_RESULT_BACKEND="redis://localhost:6379",
    CELERY_ACCEPT_CONTENT=["application/json"],
    CELERY_TASK_SERIALIZER="json",
    CELERY_RESULT_SERIALIZER="json",
    CELERYBEAT_SCHEDULE={
        'runs-every-30-seconds': {
            'task': '__main__.test',
            'schedule': timedelta(seconds=30),
        },
    }
)

if __name__ == '__main__':
   app.worker_main()

但是,如何从同一模块启动节拍过程以开始运行周期性任务(为了不将celerybeat守护程序作为单独的可执行文件运行)？这很重要,因为我想使用pyinstaller,因此客户端计算机上不会提供专用的Python解释器.

提前致谢！
让我祝你圣诞快乐,新年快乐！

最佳答案 嗯,伙计们,这项任务并不像我想象的那么难.一项小型研究让我找到答案.

可以像这样运行创建简单的节拍过程：

# that's the class to run the beat process
from celery.bin.beat import beat
# your app
from celery_tasks import app

if __name__ == "__main__":
    beat(app=app).run()

谢谢！

点赞