Tag: 芹菜

node-celery和node-amqp for RabbitMQ: 我最近一直在阅读任务队列和消息队列，对于一切如何组合，我有点困惑。我看到node-celery和node-amqp都提供了添加到RabbitMQ队列的方法。然而，节点芹菜被描述为“任务队列”，而node-amqp被描述为“RabbitMQ的客户端”。有什么不同？或者node-amqp提供的function与Celery相似吗？另外，RabbitMQ是否已经有一个队列？为什么我需要在RabbitMQ之上的芹菜？

使用节点芹菜（MeteorJS）和ampq后端时，Celery不会返回结果: 我刚开始使用Celery，一个芹菜工作人员用Python编写，并且使用node-celery从node / Meteor发送任务。为什么没有从client.call()返回result ？ Python工作控制台显示任务已经发送并成功处理。但没有任何事情ready ，似乎正在开火！使用Celery 3.1.7，RabbitMQ 3.2.2，node-celery 0.1.1，Meteor 0.7.0.1 节点 var celery = Meteor.require('node-celery'), client = celery.createClient({ CELERY_BROKER_URL: 'amqp://guest:guest@localhost:5672//', CELERY_RESULT_BACKEND: 'amqp://', CELERY_TASK_SERIALIZER: 'json', CELERY_RESULT_SERIALIZER: 'json' }); client.on('error', function(err) { console.log(err); }); client.on('connect', function() { console.log('Connected') var results = client.call('tasks.echo', ['Hello world'], function(result) { console.log('results:' + result); }); results.on('pending', function(result) { console.log('pending: […]

奇怪的行为在Redis + Node.js + Socket.io + Django /芹菜设置。断开连接的套接字仍然收到消息: 我面临着一个我自己无法解决的奇怪问题。我build立了一个设置，通过Django / Celery定期任务发送JSON序列化消息。此任务通过Redis与node.js服务器进行通信。 Node.js通过使用webbrowser的socket.io来处理通信。 Django /芹菜任务 @periodic_task(run_every=crontab()) # every minute def process_channels(): r = redis.StrictRedis(host='localhost', port=6379, db=0) for i in xrange(1,21): # 1..20 data_dict = {} data_dict['time'] = time.ctime(time.time()) data_dict['message'] = os.urandom(10).encode('hex') r.publish('channel', json.dumps(data_dict) ) time.sleep(2) node.js服务器 var http = require('http'); var server = http.createServer().listen(4000); var io = require('socket.io').listen(server); var querystring = require('querystring') […]

用另一种编程语言来使用芹菜可能吗？: 我听说芹菜，我真的很喜欢它。但是现在我正在用node.js编写一个应用程序，而且我必须pipe理（asynchronous）任务，并且我想用芹菜来实现这一点。我已经在我的开发环境中安装了它，并且使用了一些python脚本。这一切运作良好，但我想用node.js“调用”任务。有没有人试图做这样的事情（用任何编程语言）？我看到这个例子，但这个HTTP网关的基础是django应用程序，我不想创build一个django应用程序来处理这些调用。我想创build一个SimpleXMLRPCServer，并使用node-xmlrpc模块来连接。你怎么看？有更好的方法来做到这一点？是否有另一个应用程序或服务本身与node.js工作？提前致谢。