Commit b477d522 authored by 邱阿朋's avatar 邱阿朋

refactor(return_goods, spa_search): 更新 RabbitMQ 连接配置- 在 return_goods.py 和...

refactor(return_goods, spa_search): 更新 RabbitMQ 连接配置- 在 return_goods.py 和 spa_search.py 中更新了 RabbitMQClient 的主机地址和端口号
- return_goods.py 中注释掉了旧的连接配置,使用了新的生产环境配置
- spa_search.py 中同样更新了连接配置,并注释掉了旧的测试环境配置
parent a46559b1
No preview for this file type
No preview for this file type
......@@ -112,8 +112,8 @@ def main():
def push_data_queue(file_name):
rabbit = rabbitmq.RabbitMQClient(host='172.18.218.11', port=5672, username='test', password='khd123456')
# rabbit = rabbitmq.RabbitMQClient(host='47.107.31.4', port=5672, username='khd_rabbitmq', password='KHDrq2024%,,')
# rabbit = rabbitmq.RabbitMQClient(host='39.108.185.244', port=5672, username='test', password='khd123456')
rabbit = rabbitmq.RabbitMQClient(host='47.107.31.4', port=5672, username='khd_rabbitmq', password='KHDrq2024%,,')
rabbit.connect(queue='return_robot', routing_key='return_robot', exchange='reports')
data = pd.read_excel(file_name)
......
......@@ -307,7 +307,8 @@ def save_excel(sheet_data, large_sheet_data, new_file_name):
def push_data_queue(file_name):
rabbit = rabbitmq.RabbitMQClient(host='47.107.31.4', port=15672, username='khd_rabbitmq', password='KHDrq2024%,,')
# rabbit = rabbitmq.RabbitMQClient(host='39.108.185.244', port=5672, username='test', password='khd123456')
rabbit = rabbitmq.RabbitMQClient(host='47.107.31.4', port=5672, 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)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment