我正在使用芹菜来运行一些任务。以下是我用Python编写的芹菜任务:
@celery.task
def getOrders():
r = requests.get('http://localhost:4000/generate-orders/get-orders')
print r
下面是我的节点js代码,它调用上面定义的芹菜任务:
var schedule = require('node-schedule');
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.every_30_seconds');
});*/
client.on('connect', function() {
console.log('hi');
var j = schedule.scheduleJob('*/3 * * * *', function(){
console.log('Today is recognized by Rebecca Black!');
client.call('tasks.getOrders');
});
});
如上面的代码所述,我使用节点调度包在每 3 分钟后定期调用芹菜任务。
但是requests.get给出了错误:
代理错误:无:超过最大重试次数 URL:http://localhost:4000/generate-orders/get-orders
这可能是什么原因呢?
请编写一个 python 脚本在机器的命令行上运行。
import requests
r = requests.get('http://localhost:4000/generate-orders/get-orders')
print(r.text)
如果此操作也失败,则此 http 终结点存在问题。