我希望能够从NodeJS排队Resque作业。监控Redis命令,我看到:
1346127083.495055 "sadd" "resque:w:tasks:queues" "facebook"
1346127083.495471 "rpush" "resque:w:tasks:queue:facebook" "{\"class\":\"Hello::FacebookFriends\",\"args\":[\"2342324\"]}"
直接从Node发出这些命令似乎有效。这里有任何隐藏的错误或我不知道的事情吗?
更新:我的工作是用Ruby编写的。虽然我喜欢NodeJS并且我在JavaScript方面更加擅长,但我需要大量库,这些库在NPM中仍然没有很好的条件,例如与Twitter和Facebook通信(Twitter和Koala宝石,对于Node没有可比性的东西)。因此,我想从我的NodeJS服务启动Ruby作业。
到目前为止,我正在使用类似于coffee-resque中的此函数的东西:
enqueue: (queue, func, args) ->
@redis.sadd @key('queues'), queue
@redis.rpush @key('queue', queue),
JSON.stringify class: func, args: args || []
这里:
job = JSON.stringify
class: 'Hello::FacebookFriends'
args: [user_id, fb.id]
@redis_client.multi()
.sadd('resque:w:tasks:queues', 'facebook')
.rpush('resque:w:tasks:queue:facebook', job)
.exec()