SQS編~Simple Queue Serviceパート③~

こんにちは! 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を試してみたいと思います。

お楽しみに!!!

この記事を書いた人

aws-recipe-user