<legend id='zKCrW'><style id='zKCrW'><dir id='zKCrW'><q id='zKCrW'></q></dir></style></legend>
<i id='zKCrW'><tr id='zKCrW'><dt id='zKCrW'><q id='zKCrW'><span id='zKCrW'><b id='zKCrW'><form id='zKCrW'><ins id='zKCrW'></ins><ul id='zKCrW'></ul><sub id='zKCrW'></sub></form><legend id='zKCrW'></legend><bdo id='zKCrW'><pre id='zKCrW'><center id='zKCrW'></center></pre></bdo></b><th id='zKCrW'></th></span></q></dt></tr></i><div id='zKCrW'><tfoot id='zKCrW'></tfoot><dl id='zKCrW'><fieldset id='zKCrW'></fieldset></dl></div>

    1. <small id='zKCrW'></small><noframes id='zKCrW'>

        <bdo id='zKCrW'></bdo><ul id='zKCrW'></ul>

        <tfoot id='zKCrW'></tfoot>
      1. 芹菜:启动时启动任务

        Celery: launch task on start(芹菜:启动时启动任务)

              <bdo id='hjlcJ'></bdo><ul id='hjlcJ'></ul>
            • <i id='hjlcJ'><tr id='hjlcJ'><dt id='hjlcJ'><q id='hjlcJ'><span id='hjlcJ'><b id='hjlcJ'><form id='hjlcJ'><ins id='hjlcJ'></ins><ul id='hjlcJ'></ul><sub id='hjlcJ'></sub></form><legend id='hjlcJ'></legend><bdo id='hjlcJ'><pre id='hjlcJ'><center id='hjlcJ'></center></pre></bdo></b><th id='hjlcJ'></th></span></q></dt></tr></i><div id='hjlcJ'><tfoot id='hjlcJ'></tfoot><dl id='hjlcJ'><fieldset id='hjlcJ'></fieldset></dl></div>

              • <tfoot id='hjlcJ'></tfoot>

              • <small id='hjlcJ'></small><noframes id='hjlcJ'>

                  <tbody id='hjlcJ'></tbody>
                <legend id='hjlcJ'><style id='hjlcJ'><dir id='hjlcJ'><q id='hjlcJ'></q></dir></style></legend>

                  本文介绍了芹菜:启动时启动任务的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着跟版网的小编来一起学习吧!

                  问题描述

                  我有一个任务需要在芹菜启动时启动。此任务下一次通过回调/ETA每5分钟运行一次。

                  我找到了一些关于它的线索,但在芹菜3上似乎没有奏效的线索。

                  感谢您的帮助, 阿诺德。

                  推荐答案

                  芹菜irc频道的某个人通过使用";worker_ready.connect";信号:http://docs.celeryproject.org/en/latest/userguide/signals.html#worker-ready

                  为我提供了正确的方法
                  from celery.signals import worker_ready
                  
                  @worker_ready.connect
                  def at_start(sender, **k):
                      with sender.app.connection() as conn:
                           sender.app.send_task('app.modules.task', args,connection=conn, ...)
                  

                  现在它就像护身符一样起作用了!

                  这篇关于芹菜:启动时启动任务的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持跟版网!

                  本站部分内容来源互联网,如果有图片或者内容侵犯了您的权益,请联系我们,我们会在确认后第一时间进行删除!

                  相关文档推荐

                  groupby multiple coords along a single dimension in xarray(在xarray中按单个维度的多个坐标分组)
                  Group by and Sum in Pandas without losing columns(Pandas中的GROUP BY AND SUM不丢失列)
                  Group by + New Column + Grab value former row based on conditionals(GROUP BY+新列+基于条件的前一行抓取值)
                  Groupby and interpolate in Pandas(PANDA中的Groupby算法和插值算法)
                  Pandas - Group Rows based on a column and replace NaN with non-null values(PANAS-基于列对行进行分组,并将NaN替换为非空值)
                  Grouping pandas DataFrame by 10 minute intervals(按10分钟间隔对 pandas 数据帧进行分组)
                    <bdo id='0fQ37'></bdo><ul id='0fQ37'></ul>

                      1. <small id='0fQ37'></small><noframes id='0fQ37'>

                          <tbody id='0fQ37'></tbody>

                        <legend id='0fQ37'><style id='0fQ37'><dir id='0fQ37'><q id='0fQ37'></q></dir></style></legend><tfoot id='0fQ37'></tfoot>
                      2. <i id='0fQ37'><tr id='0fQ37'><dt id='0fQ37'><q id='0fQ37'><span id='0fQ37'><b id='0fQ37'><form id='0fQ37'><ins id='0fQ37'></ins><ul id='0fQ37'></ul><sub id='0fQ37'></sub></form><legend id='0fQ37'></legend><bdo id='0fQ37'><pre id='0fQ37'><center id='0fQ37'></center></pre></bdo></b><th id='0fQ37'></th></span></q></dt></tr></i><div id='0fQ37'><tfoot id='0fQ37'></tfoot><dl id='0fQ37'><fieldset id='0fQ37'></fieldset></dl></div>