python - 如何从豆茎管中食用
问题描述
我正在使用 beanstalk 将消息放入管中,我想从我将在运行时启动的新 EC2 实例中使用它。我可以将消息放入管中,但我无法以任何方式消费它。
我执行了以下步骤进行测试:
文件:生产者.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')
文件:消费者.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 现货实例
解决方案
你会use
用管子输入信息。从管中读取watch
一个(或多个)管,当您调用reserve
获取一个时服务器将返回一条消息
作业将仅从监视列表中的管中保留,该列表最初包含一个管,默认为。您可以使用 将管子添加到观察列表中,使用
watch
删除它们ignore
。为方便起见,可以watch
在创建客户端时使用参数进行设置。https://greenstalk.readthedocs.io/en/stable/quickstart.html#sumption-jobs
推荐阅读
- python - 缺少的属性不会被 Python 支持的 IDE 捕获
- angular - 离子加载控制器关闭不起作用
- microservices - 为什么不为 DTO 创建一个 git 子模块,它将在多个微服务之间共享以避免代码重复?
- android - “import android.view.View”中的视图和视图是什么
- python - 每当我在管理员中添加新用户时,如何在 django 管理页面中添加 Id_card_number 输入字段?
- mongodb - 如何在 MongoDB 中存储整本书文本(用阿拉伯语/乌尔都语编写),这样我以后可以从中搜索文本?
- docker - 如何将参数传递给 docker ENTRYPOINT 中的 bash 文件?
- lisp - ecl_init_module 中的第一个参数有什么作用?
- vba - 在 PowerPoint 中修改树形图
- sql - T-sql 选择xml值