1

我正在使用 node-celery github 链接与 rabbitmq 一起 实现 celery celery 第一步。

就像在 celery 中一样，我们定义任务然后推送它们。

我在tasks.py中定义的任务如下：

import os
import logging
from celery import Celery
import requests

backend = os.getenv('CELERY_BACKEND_URL', 'amqp')
celery = Celery('tasks', backend=backend)

celery.conf.update(
    CELERY_RESULT_SERIALIZER='json',
    CELERY_ENABLE_UTC=True
)

@celery.task
def getOrders():
    requests.get('locahost:4000/getOrders')

我运行以触发任务的文件：

eta.js：

  var celery = require('../celery'),
        client = celery.createClient({
            CELERY_BROKER_URL: 'amqp://guest:guest@localhost:5672//'
     });
    
    
    
    client.on('error', function(err) {
        console.log(err);
    });
    
    client.on('connect', function() {
        client.call('tasks.getOrders', {
            eta: new Date(Date.now() + 15 * 1000) // an hour later
        });
    });

我使用以下命令启动 celery worker：

celery worker -A tasks -l info

现在，当我运行 eta.js 并且我在 tasks.py 中定义的任务“getOrders”获得触发器时，它进一步点击了我请求的 url，并且该 URL 完成了它的工作。

要运行 eta.js，我运行：

 node eta.js

我想要的是我的任务“getOrders”每 x 秒后继续运行。我已经阅读了有关在 celery周期性任务 celery中设置周期性任务的信息，但它在 python 中，我在 node-celery 中需要它。

如果可能的话，我想在节点芹菜中使用芹菜节拍，还是应该避免使用节点芹菜？并使用 celery python setup，我知道 python，但找不到在 python 中设置 celery 的任何链接。

任何对芹菜有很好了解的人都可以帮助我或指导我学习一些教程。

谢谢！

4

1 回答 1

0

您可以直接将计划任务添加到 Redis，这样 Redbeat 将读取这个新任务并执行它并根据 crontab 设置重新安排它。

去做这个：

  1. 在 celery 配置中添加 redbead redis url
  2. 创建周期性任务
const task = {
     name : "getOrdersTask",
     task : "tasks.getOrders",
     schedule: {
         "__type__": "crontab",
         minute : "*/5",
         hour : "*",
         day_of_week :
         day_of_month : "*/7"
         month_of_year : "[1-12]"
     },
     args : [],
     enabled : true,
}

  1. 将任务存储在 redis 中：

    redisClient.hset("redbeat:getOrdersTask", "definition", JSON.stringify(task));

  2. 将任务插入任务列表（0 是强制 Redbeat 立即执行它，以便根据您选择的周期配置在适当的时间重新安排它，在这种情况下每 5 分钟一次）

    redisClient.zadd("redbeat::schedule", 0, "getOrdersTask")
于 2019-02-22T09:07:29.730 回答