Simple Message Queue (formerly MNS):SMQ SDK for Python を使用した Topic へのメッセージ送信

ステップ 1：アカウントの初期化と Topic の取得

エンドポイントおよび認証情報を用いて Account オブジェクトを作成し、対象 Topic の参照を取得します。

my_account = Account(endpoint, accid, acckey, token)
topic_name = sys.argv[1] if len(sys.argv) > 1 else "MySampleTopic"
my_topic = my_account.get_topic(topic_name)

ステップ 2：生（Raw）メッセージの送信

TopicMessage を使用して、エンコーディングを行わずにメッセージを送信します。

msg_count = 3

for i in range(msg_count):
    try:
        msg_body = u"I am test message %s." % i
        msg = TopicMessage(msg_body)
        re_msg = my_topic.publish_message(msg)
        print("Publish Raw Message Succeed. MessageBody:%s MessageID:%s" % (msg_body, re_msg.message_id))
    except MNSExceptionBase as e:
        if e.type == "TopicNotExist":
            print("Topic not exist, please create it.")
            sys.exit(1)
        print("Publish Raw Message Fail. Exception:%s" % e)

• TopicMessage(msg_body) は、メッセージ本文を生（Raw）形式（エンコーディングなし）でラップします。

• my_topic.publish_message(msg) は、メッセージを Topic に送信し、message_id を含む応答を返します。

• Topic が存在しない場合、SDK は MNSExceptionBase を発生させ、その e.type 属性が "TopicNotExist" に設定されます。

ステップ 3：Base64 エンコード済みメッセージの送信

Base64TopicMessage を使用して、送信前にメッセージ本文を Base64 エンコードします。

for i in range(msg_count):
    try:
        msg_body = u"I am test message %s." % i
        msg = Base64TopicMessage(msg_body)
        re_msg = my_topic.publish_message(msg)
        print("Publish Base64 Encoded Message Succeed. MessageBody:%s MessageID:%s" % (msg_body, re_msg.message_id))
    except MNSExceptionBase as e:
        if e.type == "TopicNotExist":
            print("Topic not exist, please create it.")
            sys.exit(1)
        print("Publish Base64 Encoded Message Fail. Exception:%s" % e)

ステップ 2 との唯一の違いは、使用するメッセージクラスです。Base64TopicMessage は、送信前にメッセージ本文を自動的に Base64 エンコードします。