主題+HttpEndpoint使用手冊__Python SDK_SDK使用手冊_消息服務-阿裏雲

本文檔介紹如何使用python sdk中的sample代碼，完成創建主題、創建訂閱、啟動 HttpEndpoint、發布消息、查看HttpEndpoint接收消息和刪除主題操作。

1. 準備

下載最新版python sdk，解壓後進入mns_python_sdk子目錄；
打開sample.cfg文件，配置AccessKeyID、AccessKeySecret和Endpoint；
- AccessKeyId、AccessKeySecret
  - 訪問阿裏雲API的密鑰對；
  - 如果使用主賬號訪問，登陸阿裏雲 AccessKey 管理頁麵創建、查看；
  - 如果使用子賬號訪問，請登錄阿裏雲訪問控製控製台查看；
- Endpoint
  - 訪問MNS的接入地址，登陸MNS控製台單擊右上角 獲取Endpoint 查看;
  - 不同地域的接入地址不同；
- SecurityToken
  - 阿裏雲訪問控製服務提供的短期訪問權限憑證，直接使用阿裏雲賬號或者子賬號訪問不需要配置該項，了解詳情;
進入sample目錄，後續使用的腳本都在這裏；

2. 創建主題

運行 createtopic.py 創建主題;
默認創建的主題名稱是 MySampleTopic，也可以通過參數指定主題名稱；
主題詳細信息請參考詳情;

運行

$python createtopic.py MyTopic1
Create Topic Succeed! TopicName:MyTopic1

核心代碼

endpoint，accid，acckey和token從第1步的配置文件中讀取；

#init my_account, my_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)
#you can get more information of TopicMeta from mns/topic.py
topic_meta = TopicMeta()
try:
    topic_url = my_topic.create(topic_meta)
    print "Create Topic Succeed! TopicName:%sn" % topic_name
except MNSExceptionBase, e:
    if e.type == "TopicAlreadyExist":
        print "Topic already exist, please delete it before creating or use it directly."
        sys.exit(0)
    print "Create Topic Fail! Exception:%sn" % e

`3. 啟動 HttpEndpoint`

運行 simple_http_notify_endpoint.py 啟動 HttpEndpoint；腳本啟動後，輸出該腳本的監聽地址，這個地址後續作為創建訂閱的Endpoint參數，用於接收 MNS 推送消息的請求；


服務器功能
對 MNS 推送消息請求做簽名驗證，如果錯誤，返回MNS 403；
解析推送請求的 body，打印到日誌中，如果解析錯誤，返回MNS 400；
如果驗權和解析 body 均正常，返回 MNS 201；
運行 
$python simple_http_notify_endpoint.py 
Start Endpoint! Address: https://10.101.161.37:8080
由於 simple_http_notify_endpoint.py 的代碼較多，請直接查看sdk 中的源碼。
4. 創建訂閱
運行 subscribe.py 創建訂閱；
第一個參數指定接收消息的 HttpEndpoint，使用第3步中腳本輸出的Address；
第二個參數指定訂閱的主題名稱，如果第2步中指定了主題名稱，這裏同樣指定主題名稱；
第三個參數指定訂閱的名稱，默認是 MySampleTopic-Sub；
訂閱詳細信息請參考詳情;
運行
$python subscribe.py https://10.101.161.37:8080 MyTopic1 MyTopic1-Sub1
Create Subscription Succeed! TopicName:MyTopic1 SubName:MyTopic1-Sub1 Endpoint:https://10.101.161.37:8080
核心代碼
endpoint，accid，acckey和token從第1步的配置文件中讀取；
sub_endpoint = sys.argv[1]
#init my_account, my_topic, my_sub
my_account = Account(endpoint, accid, acckey, token)
topic_name = sys.argv[2] if len(sys.argv) > 2 else "MySampleTopic"
my_topic = my_account.get_topic(topic_name)
sub_name = sys.argv[3] if len(sys.argv) > 3 else "MySampleTopic-Sub"
my_sub = my_topic.get_subscription(sub_name)
#you can get more information of SubscriptionMeta from mns/subscription.py
sub_meta = SubscriptionMeta(sub_endpoint)
try:
    topic_url = my_sub.subscribe(sub_meta)
    print "Create Subscription Succeed! TopicName:%s SubName:%s Endpoint:%sn" % (topic_name, sub_name, sub_endpoint)
except MNSExceptionBase, e:
    if e.type == "TopicNotExist":
        print "Topic not exist, please create topic."
        sys.exit(0)
    elif e.type == "SubscriptionAlreadyExist":
        print "Subscription already exist, please unsubscribe or use it directly."
        sys.exit(0)
    print "Create Subscription Fail! Exception:%sn" % e
5. 發布消息
運行publishmessage.py 發布多條消息到主題中；
如果第2步中指定了主題名稱，這裏同樣通過第一個參數指定主題名稱；
消息詳細信息請參考詳情;

運行
$python publishmessage.py MyTopic1
==========Publish Message To Topic==========
TopicName:MyTopic1
MessageCount:3
Publish Message Succeed. MessageBody:I am test message 0. MessageID:F6EA56633844DBFC-1-154BDFB8059-200000004
Publish Message Succeed. MessageBody:I am test message 1. MessageID:F6EA56633844DBFC-1-154BDFB805F-200000005
Publish Message Succeed. MessageBody:I am test message 2. MessageID:F6EA56633844DBFC-1-154BDFB8062-200000006
核心代碼
endpoint，accid，acckey和token從第1步的配置文件中讀取；

#init my_account, my_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)
#publish some messages
msg_count = 3
print "%sPublish Message To Topic%snTopicName:%snMessageCount:%sn" % (10*"=", 10*"=", topic_name, msg_count)
for i in range(msg_count):
    try:
        msg_body = "I am test message %s." % i
        msg = TopicMessage(msg_body)
        re_msg = my_topic.publish_message(msg)
        print "Publish Message Succeed. MessageBody:%s MessageID:%s" % (msg_body, re_msg.message_id)
    except MNSExceptionBase,e:
        if e.type == "TopicNotExist":
            print "Topic not exist, please create it."
            sys.exit(1)
        print "Publish Message Fail. Exception:%s" % e
6. 查看 HttpEndpoint 接收消息
第5步發布了多條消息到主題中，MNS 會將發布的消息推送給第3步啟動的 HttpEndpoint；
HttpEndpoint 在接收到消息推送請求後，會記錄兩種日誌：access_log 和 endpoint_log；

access log啟動 HttpEndpoint 的地方會打印access log，顯示推送消息請求的基本信息，從左往右依次是：
RequestTime RequestVersion ReturnCode URI HTTPVersion RequestLength Host Agent MNSRequestID MNSVersion
除打印到屏幕上，access log會寫到日誌文件中，文件名格式是access_log.$port，本文檔對應的日誌文件是access_log.8080；
第5步發布消息對應的推送請求access log如下：
$python simple_http_notify_endpoint.py
Start Endpoint! Address: https://10.101.161.37:8080
[17/May/2016 17:10:56]"POST" "201" "/notifications" "HTTP/1.1" "495" "10.101.161.37:8080" "Aliyun Notification Service Agent" "573AE020B2B71CFC6801A6EF" "2015-06-06"
[17/May/2016 17:10:56]"POST" "201" "/notifications" "HTTP/1.1" "495" "10.101.161.37:8080" "Aliyun Notification Service Agent" "573AE020B2B71CFC6801A712" "2015-06-06"
[17/May/2016 17:10:56]"POST" "201" "/notifications" "HTTP/1.1" "495" "10.101.161.37:8080" "Aliyun Notification Service Agent" "573AE020B2B71CFC6801A704" "2015-06-06"
endpoint log記錄每個請求的詳細信息，包含完整的header、body以及解析後消息各屬性的信息；
日誌的文件名格式是 endpoint_log.$port，本文檔對應的日誌文件是endpoint_log.8080
第5步發布消息對應的推送請求的endpoint log如下：
$cat endpoint_log.8080
...
[2016-05-17 17:10:56] [root] [INFO] [simple_http_notify_endpoint.py:47] [1096657216] Notify Message Succeed!
MessageMD5                    : 075C3D4AEB2D2F2D6A4C17C9D6DBBEBB
TopicOwner                    : 1269128356620446
PublishTime                   : 1463476256857
Subscriber                    : 1269128356620446
MessageTag                    :
SubscriptionName              : MyTopic1-Sub1
MessageId                     : F6EA56633844DBFC-1-154BDFB8059-200000004
Message                       : I am test message 0.
TopicName                     : MyTopic1
[2016-05-17 17:10:56] [root] [INFO] [simple_http_notify_endpoint.py:47] [1123260736] Notify Message Succeed!
MessageMD5                    : 3BCFB142A3CC597F5D409BFE9DB1B885
TopicOwner                    : 1269128356620446
PublishTime                   : 1463476256866
Subscriber                    : 1269128356620446
MessageTag                    :
SubscriptionName              : MyTopic1-Sub1
MessageId                     : F6EA56633844DBFC-1-154BDFB8062-200000006
Message                       : I am test message 2.
TopicName                     : MyTopic1
[2016-05-17 17:10:56] [root] [INFO] [simple_http_notify_endpoint.py:47] [1112770880] Notify Message Succeed!
MessageMD5                    : 8356BC7FFBD22CC971BE7FF7427202B6
TopicOwner                    : 1269128356620446
PublishTime                   : 1463476256863
Subscriber                    : 1269128356620446
MessageTag                    :
SubscriptionName              : MyTopic1-Sub1
MessageId                     : F6EA56633844DBFC-1-154BDFB805F-200000005
Message                       : I am test message 1.
TopicName                     : MyTopic1
7. 刪除主題
運行deletetopic.py 刪除主題；
如果第2步中指定了主題名稱，這裏同樣通過第一個參數指定主題名稱；

運行
$python deletetopic.py MyTopic1
Delete Topic Succeed! TopicName:MyTopic1
核心代碼
#init my_account, my_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)
try:
    my_topic.delete()
    print "Delete Topic Succeed! TopicName:%sn" % topic_name
except MNSExceptionBase, e:
    print "Delete Topic Fail! Exception:%sn" % e
 最後更新：2016-11-23 17:16:08
  上一篇： 並發測試示例代碼__Java SDK_SDK使用手冊_消息服務-阿裏雲
  下一篇： 主題+QueueEndpoint使用手冊__Python SDK_SDK使用手冊_消息服務-阿裏雲
相關內容
 添加後端服務器__實例管理_用戶指南_負載均衡-阿裏雲
 圖片鑒黃異步調用接口__智能圖片鑒黃API_內容檢測API文檔_阿裏綠網-阿裏雲
 發送消息__隊列消息操作_快速入門_消息服務-阿裏雲
 數據轉發到DataHub__規則引擎_控製台使用手冊_阿裏雲物聯網套件-阿裏雲
 阿裏雲總裁胡曉明：幫助企業完成技術創新，做有溫度的阿裏雲
 發布服務__使用說明_用戶手冊_雲服務總線 CSB-阿裏雲
 簽名算法參考__OpenAPI使用手冊_雲監控-阿裏雲
 新購__購買實例_購買指南_雲服務器 ECS-阿裏雲
 刪除指定的 ECU__資源管理類 API_Open API 參考_企業級分布式應用服務 EDAS-阿裏雲
 發送定時消息__Java SDK_TCP 接入(專業)_消息隊列 MQ-阿裏雲
熱門內容
 常見錯誤說明__附錄_大數據計算服務-阿裏雲
 發送短信接口__API使用手冊_短信服務-阿裏雲
 接口文檔__Android_安全組件教程_移動安全-阿裏雲
 運營商錯誤碼（聯通）__常見問題_短信服務-阿裏雲
 設置短信模板__使用手冊_短信服務-阿裏雲
 OSS 權限問題及排查__常見錯誤及排除_最佳實踐_對象存儲 OSS-阿裏雲
 消息通知__操作指南_批量計算-阿裏雲
 設備端快速接入(MQTT)__快速開始_阿裏雲物聯網套件-阿裏雲
 查詢API調用流量數據__API管理相關接口_API_API 網關-阿裏雲
 使用STS訪問__JavaScript-SDK_SDK 參考_對象存儲 OSS-阿裏雲
最新內容
 阿裏雲服務器高效分機設置與管理詳解
 阿裏雲電腦管家深度使用指南：全麵提升電腦性能與安全
 阿裏雲發展曆程與馬雲的戰略思想
 阿裏雲OSS對象存儲：高效下載與打印文件夾內容的完整指南
 阿裏雲餘額如何用於股票投資？詳解阿裏雲餘額與股票交易的關聯
 阿裏雲智能會員注冊及權益深度解讀
 阿裏雲高效壓縮文件夾技巧及最佳實踐
 阿裏雲盤如何模擬本地硬盤使用？深度解析及技巧
 馬雲並非阿裏巴巴創始人？深度解讀其早期角色與入職秘辛
 騰訊雲和阿裏雲：詳解雲計算巨頭的業務模式及市場定位

主題+HttpEndpoint使用手冊__Python SDK_SDK使用手冊_消息服務-阿裏雲

1. 準備

2. 創建主題

`3. 啟動 HttpEndpoint`

4. 創建訂閱

`5. 發布消息`

`6. 查看 HttpEndpoint 接收消息`

7. 刪除主題

上一篇：並發測試示例代碼__Java SDK_SDK使用手冊_消息服務-阿裏雲

下一篇：主題+QueueEndpoint使用手冊__Python SDK_SDK使用手冊_消息服務-阿裏雲

相關內容

熱門內容

最新內容

主題+HttpEndpoint使用手冊__Python SDK_SDK使用手冊_消息服務-阿裏雲

1. 準備

2. 創建主題

3. 啟動 HttpEndpoint

4. 創建訂閱

5. 發布消息

6. 查看 HttpEndpoint 接收消息

7. 刪除主題

上一篇： 並發測試示例代碼__Java SDK_SDK使用手冊_消息服務-阿裏雲

下一篇： 主題+QueueEndpoint使用手冊__Python SDK_SDK使用手冊_消息服務-阿裏雲

相關內容

熱門內容

最新內容

`3. 啟動 HttpEndpoint`

`5. 發布消息`

`6. 查看 HttpEndpoint 接收消息`

上一篇：並發測試示例代碼__Java SDK_SDK使用手冊_消息服務-阿裏雲

下一篇：主題+QueueEndpoint使用手冊__Python SDK_SDK使用手冊_消息服務-阿裏雲