更新RabbitMQ配置并启用消息推送

src/return_goods.py

@@ -107,11 +107,11 @@ def main():
     excel.save_xls(new_list_data, new_file_name)
 
     # 推送消息
-    # push_data_queue(new_file_name)
+    push_data_queue(new_file_name)
 
 
 def push_data_queue(file_name):
-    rabbit = rabbitmq.RabbitMQClient(host='172.18.218.11', port=15672, username='test', password='khd123456')
+    rabbit = rabbitmq.RabbitMQClient(host='47.107.31.4', port=15672, username='khd_rabbitmq', password='KHDrq2024%,,')
     rabbit.connect(queue='return_robot', routing_key='return_robot', exchange='reports')
 
     data = pd.read_excel(file_name)

src/spa_search.py

@@ -307,7 +307,7 @@ def save_excel(sheet_data, large_sheet_data, new_file_name):
 
 
 def push_data_queue(file_name):
-    rabbit = rabbitmq.RabbitMQClient(host='172.18.218.11', port=15672, username='test', password='khd123456')
+    rabbit = rabbitmq.RabbitMQClient(host='47.107.31.4', port=15672, username='khd_rabbitmq', password='KHDrq2024%,,')
     rabbit.connect(queue='spa_robot', routing_key='spa_robot', exchange='reports')
     log.info("开始读取数据....")
     data_dict = pd.read_excel(file_name, sheet_name=None)