feat: 添加rabbitmq地址

data_clean/env/env-dev.yaml

@@ -77,3 +77,4 @@ rabbit_mq:
     host: 106.15.78.184
     username: whc
     password: whc
+    port: 32675

data_clean/env/env-prod.yaml

@@ -47,6 +47,7 @@ holo:
 
 rabbit_mq:
   base:
-    host: 192.168.2.63
+    host: lavinmq.rabbitmq
     username: whc
-    password: whc
+    password: whc
+    port: 32675

data_clean/utils/async_client.py

@@ -44,7 +44,8 @@ async def get_rabbitmq_connection(name: str = "base") -> AbstractRobustConnectio
     host = _env.get_val('rabbit_mq.' + name + '.host')
     username = _env.get_val('rabbit_mq.' + name + '.username')
     password = _env.get_val('rabbit_mq.' + name + '.password')
-    port = 32675
+    port = int(_env.get_val('rabbit_mq.' + name + '.port'))
+    # port = 32675
     virtual_host = '/'
 
     loop = asyncio.get_event_loop()