add

push_to_mq.py

@@ -3,10 +3,16 @@ import json
 import pika
 
 # 推送消息到 mq测试脚本
+#
+# username = 'huntadmin'
+# password = 'jy2y2900'
+# host = '192.168.1.237'
+# port = 5672
+# queue_name = 'liexin_nplm_filter_sku_data'
 
 username = 'huntadmin'
 password = 'jy2y2900'
-host = '192.168.1.237'
+host = '172.18.137.29'
 port = 5672
 queue_name = 'liexin_nplm_filter_sku_data'
 
@@ -29,6 +35,24 @@ def push_mq(message: str):
 # {"goods_id":1170115972487102103,"spu_id":2170115972437912400,"platform":1,"shop_id":1}
 
 if __name__ == '__main__':
-    data = {"goods_id": 1170122329267322783, "spu_id": 2170122329155225702, "platform": 1, "shop_id": 1}
+    data = {"goods_id": 1151525960495265804, "spu_id": 2151133166540743705, "platform": 1, "shop_id": 2}
+    msg = json.dumps(data, ensure_ascii=False)
+    push_mq(msg)
+
+
+    data = {"goods_id": 1151033368840495919, "spu_id": 2151033368813527600, "platform": 1, "shop_id": 2}
+    msg = json.dumps(data, ensure_ascii=False)
+    push_mq(msg)
+
+    data = {"goods_id": 1151033372498623926, "spu_id": 2151033372494531806, "platform": 1, "shop_id": 2}
+    msg = json.dumps(data, ensure_ascii=False)
+    push_mq(msg)
+
+    data = {"goods_id": 1171169666318406723, "spu_id": 2151033370259441104, "platform": 1, "shop_id": 2}
+    msg = json.dumps(data, ensure_ascii=False)
+    push_mq(msg)
+
+
+    data = {"goods_id": 1151033368983156030, "spu_id": 2151033369155518807, "platform": 1, "shop_id": 2}
     msg = json.dumps(data, ensure_ascii=False)
     push_mq(msg)
\ No newline at end of file