启动文件修改

communication/rabbitmq_link.py

@@ -79,13 +79,13 @@ class PikaMessage(object):
         """
         # self.publish_msg_to_delay_queue(body)
         data_from_rabbitmq = body.decode()
-        from main import main
+        from cop_main import main
         main(data_from_rabbitmq)
 
     @staticmethod
     def callback_delay(ch, method, properties, body):
         data_from_rabbitmq = body.decode()
-        from main import main
+        from cop_main import main
         main(data_from_rabbitmq)
 
     def consume(self):

communication/rocketmq_link.py

@@ -126,7 +126,7 @@ class RocketClient:
         logger.critical(f'[RocketClient] send msg to  {topic}:{tags}')
 
 def on_rocket_msg(cop_msg:ReceivedMessage):
-    from main import main
+    from cop_main import main
     try:
         main(cop_msg.body.decode())
         return ConsumeStatus.CONSUME_SUCCESS

startup.sh

@@ -1,2 +1,2 @@
 source /opt/alg/alg_env/bin/activate && \
-nohup python3 main.py  >> /var/log/cop.log  2>&1 &
+nohup python3 cop_main.py  >> /var/log/cop.log  2>&1 &