こんにちは! JQです。
前回は『 SQS編~Simple Queue Service パート②~ 』と題して、CLIでSQSを試してみました。
今回は『SQS編~Simple Queue Service パート③~』と題して、AWS SDK for Python(Boto)でSQSを試してみたいと思います。
AWS SDK for Python(Boto)設定
1. AWS SDK for Python(Boto)の設定
AWS SDK for Python(Boto)の設定を行っておきます。
※詳細は以前の記事をご参照ください。
■EC2編~Amazon Linux Python Update 2.7~
2. キューの作成
先ずはキューを作成してみます。
1>>> import boto.sqs2>>> conn = boto.sqs.connect_to_region("ap-northeast-1")3>>> q = conn.create_queue('TestQueue')4>>> conn.get_all_queues()5[Queue(https://ap-northeast-1.queue.amazonaws.com/[AWSAccountID]/TestQueue)]6>>> q7Queue(https://ap-northeast-1.queue.amazonaws.com/[AWSAccountID]/TestQueue)3. メッセージ送信
作成したキューにメッセージを送信してみます。
1>>> from boto.sqs.message import Message2>>> m = Message()3>>> m.set_body('Test message.')4>>> q.write(m)5<boto.sqs.message.Message object at 0xfc6950>4. メッセージ受信
送信したメッセージを受信してみます。
1>>> rs = q.get_messages()2>>> rs3[<boto.sqs.message.Message object at 0xfd8a10>]4>>> rs[0]5<boto.sqs.message.Message object at 0xfd88d0>6>>> rs[0].get_body()7'Test message.'5. メッセージ削除
キューにあるメッセージを削除してみます。
1>>> q.delete_message(rs[0])2True再度メッセージを取得して確認してみます。
1>>> rs = q.get_messages()2>>> rs3[]正しく削除出来ました。
6. キュー削除
最後にキューを削除してみます。
1>>> conn.delete_queue(q)2True削除出来たか確認してみます。
1>>> conn.get_all_queues()2[]いかがでしたでしょうか?
次回は『SQS編~Simple Queue Service パート④~』と題して、AWS SDK for RubyでSQSを試してみたいと思います。
お楽しみに!!!