[GitHub] [rocketmq-client-python] zuoyc opened a new issue #123: why 2?

[GitBox <gi...@apache.org>]

zuoyc opened a new issue #123:
URL: https://github.com/apache/rocketmq-client-python/issues/123


   class RocketMQ():
       def __init__(self):
           logging.basicConfig(level=logging.CRITICAL, format='%(asctime)s - %(name)s - %(levelname)s - %(message)s')
           self.logger = logging.getLogger(__name__)
           self.consumer = PushConsumer("CID_test")
           self.consumer.set_namesrv_addr("114.214.170.219:9876")
           self.topic_name = "MESSAGE_PUSH_SYSTEM_TO_ALGO"
           self.timeHash=[]
   
           #减少日志输出
           dll.SetPushConsumerLogLevel(namesrv_addr.encode('utf-8'), 1)
       def callback(self,msg):
           test_body = json.loads(msg)
           self.my_func(test_body)
   
       def onMessage(self):
           self.consumer.subscribe(self.topic_name, self.callback)
           self.consumer.start()
           while True:
               time.sleep(30)
           self.consumer.shutdown()
       def my_func(self,data):
           print(data)
           result = self.swlTask(data)
           tem["id"] = data["id"]
           tem["cameraId"] = data["deviceId"]
           tem["makedPic"] = os.path.join(time.strftime('%Y%m%d', time.localtime()), result)
           sum.append(tem)
           # 否开启子进程来跑模型输出的结果
           cmd = "cd /home/algo/matching;python demo.py"
           with os.popen(cmd) as p:
               for index in p.readlines():
                   tem = index
                   if "Complete registration" in tem:
                       if str(tem).split(" ")[0] in self.timeHash:
                           self.timeHash.remove(str(tem).split(" ")[0])
                       self.timeHash.append(str(tem).split(" ")[0])
                       print("aaa:", self.timeHash)
                       A = time.time()
           self.product(sum)
           cmd1 = "cd /home/algo/matching/Images/real; rm -rf *"
           re1 = os.popen(cmd1)
           cmd2 = "cd /home/algo/matching/Images/vir; rm -rf *"
           re2 = os.popen(cmd2)
           cmd3 = "cd /home/algo/matching/Images/sem; rm -rf *"
           re3 = os.popen(cmd3)
   
       def swlTask(msg):  # 算法组从MQ中获得待处理的图片
           image1 = msg["truePic"]  # 真实
           image2 = msg["modelPic"]  # 虚拟
           image3 = msg["transPic"]  # 语义
           print(image1, image2, image3)
           savedir = "/home/algo/matching/Images"
           try:
               real = os.path.join(savedir, "real", image1.split("/")[-1])
               vir = os.path.join(savedir, "vir", image1.split("/")[-1])
               sem = os.path.join(savedir, "sem", image1.split("/")[-1])
           except:
               pass
           else:
               shutil.copyfile(image1, real)
               shutil.copyfile(image2, vir)
               shutil.copyfile(image3, sem)
               print("what", image1.split("/")[-1])
               return image1.split("/")[-1]
   
       def product(sum):  # 算法组推送图片合成信息
           print("1")
           producer = Producer('test')
           producer.set_namesrv_addr('')  # rocketmq队列接口地址（服务器ip:port）
   
           producer.start()
           msg_body = {
               "result": sum
           }
           ss = json.dumps(msg_body).encode('utf-8')
           msg = Message("xxx")  # topic名称
           msg.set_tags('xxx')
           msg.set_body(ss)
           ret = producer.send_sync(msg)
           producer.shutdown()
   when id(self.timeHash),there are two address,why?


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org