如何在Python上将函数传递给arq工作者

发布于 2025-01-11 02:15:11 字数 284 浏览 0 评论 0原文

使用某些函数运行 arq Worker，该函数有一些任务要做，但要执行以下任务。 arq import Worker

w = Worker(functions=[],
    redis_settings=WorkerSettings.redis_settings(),
    max_jobs=1000,
    keep_result_forever=True,
    job_timeout=86000,
    max_tries=1000)
w.run()

缺少单个函数时出错

原文

Run arq worker with some function that have some task to do but getting for below one.
arq import Worker

w = Worker(functions=[],
    redis_settings=WorkerSettings.redis_settings(),
    max_jobs=1000,
    keep_result_forever=True,
    job_timeout=86000,
    max_tries=1000)
w.run()

Error on missing single function

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

独留℉清风醉 2025-01-18 02:15:11

您需要一个工作人员应该运行的函数。否则工人就完全没有必要了。

例如，使用函数 the_tasks，将其添加到工作线程的 functions 参数中：

arq import Worker

async def the_task(ctx):
    print('running the task')
    return 42

w = Worker(functions=[the_task],
    redis_settings=WorkerSettings.redis_settings(),
    max_jobs=1000,
    keep_result_forever=True,
    job_timeout=86000,
    max_tries=1000)
w.run()

也许从演示示例开始：https://arq-docs.helpmanual.io/#simple-usage

You need a function that the worker should run. Otherwise the worker would be quite unnecessary.

For example with the function the_tasks, you add it to the functions argument of the worker:

arq import Worker

async def the_task(ctx):
    print('running the task')
    return 42

w = Worker(functions=[the_task],
    redis_settings=WorkerSettings.redis_settings(),
    max_jobs=1000,
    keep_result_forever=True,
    job_timeout=86000,
    max_tries=1000)
w.run()

Maybe start with the demo example: https://arq-docs.helpmanual.io/#simple-usage

回复收藏 0 原文

~没有更多了~