我使用Phalcon php服务器端,我发送工作到beanstalk的doc说。
执行所有作业在beanstalk我有一个python脚本。该脚本搜索是否存在现有作业并执行它们。但是现在我用linux命令行执行这个脚本。
然后,我想在创建作业并执行任务时自动执行我的python脚本。我想到了套接字
是否有可能在beanstalk socket事件接收到作业并执行我的python脚本时捕获它?
最后我用Tornado Beanstalkt写了一个python脚本。
这是我的代码。
import tornado
import beanstalkt
def show(msg, value, cb):
print(msg % value)
cb()
def stop():
client.close(ioloop.stop)
def connect(s):
print('Connection established')
reserve()
def reserve():
client.reserve(callback=lambda s: show(
"Reserved job %s", s, lambda: delete(s["id"])))
def delete(job_id):
client.delete(job_id, callback=lambda s: show(
"Deleted job with id %d", job_id, reserve))
ioloop = tornado.ioloop.IOLoop.instance()
client = beanstalkt.Client(host='my-server', port=11300)
client.connect(callback=connect)
client.watch("my-tube")
ioloop.start()
这一行将建立到我的beanstalk服务器的连接。
client.connect(callback=connect)
client.watch("my-tube")
ioloop.start()
一旦连接成功,我将启动worker,这就是为什么我在connect
方法中使用回调。watch
方法专注于我想要的管,start
方法将启动异步循环无阻塞I/o
在我的connect
函数我将调用reserve
函数。如果没有可保留的作业,也没有给出超时,那么reserve
将等待未来的作业,并将使用beanstalk套接字触发。
之后,我可以在reserve
函数中给出我想要的东西。这里我发送show函数来测试我的进程。在我打印之后,我将调用delete回调来删除当前的作业。
希望能有所帮助。