如何从豆茎管中食用答案

【问题标题】：How to consume from beanstalk tube如何从豆茎管中食用
【发布时间】：2021-07-12 10:00:24
【问题描述】：

我正在使用 beanstalk 将消息放入管中，我想从我将在运行时启动的新 EC2 实例中使用它。我可以将消息放入试管中，但我无法以任何方式使用它。

我执行了以下步骤进行测试：

文件：producer.py

#!/usr/bin/env python
import greenstalk
import json
import sys

beanstalkTube = 'tube-name'
beanstalkHost = 'host'
beanstalkPort = 11301

client = greenstalk.Client((beanstalkHost, beanstalkPort))
client.use(beanstalkTube)

client.put('message 1')

文件：consumer.py

#!/usr/bin/env python
import greenstalk
import json
import sys

beanstalkTube = 'tube-name'
beanstalkHost = 'host'
beanstalkPort = 11301

client = greenstalk.Client((beanstalkHost, beanstalkPort))
client.use(beanstalkTube)


job = client.reserve()

print("job_id:"+job.id)
print("job_body:"+job.body)

我想知道的另一件事是我应该如何使用 beanstalk 通过 shell 脚本将消息传递给新创建的 EC2 点实例

【问题讨论】：

标签： python amazon-web-services beanstalkd beanstalkc

【解决方案1】：

您将use 一个管子输入消息。从管中读取，您 watch 一个（或多个）管，当您调用 reserve 获取一个时服务器将返回一条消息

作业只会从观察列表中的管中保留，该列表最初包含一个管，默认。您可以使用watch 将管添加到监视列表，并使用ignore 将其删除。为方便起见，可以在创建客户端时使用watch 参数进行设置。 https://greenstalk.readthedocs.io/en/stable/quickstart.html#consuming-jobs

【讨论】：