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')
ファイル: 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)
もう 1 つ知りたいことは、Beanstalk を使用して、シェル スクリプトを介して新しく作成された EC2 スポット インスタンスにメッセージを渡す方法です。