Python 5.0.6 (#1004)

* Python 5.0.6

Author: zhouli11

python/rocketmq/v5/client/balancer/queue_selector.py

@@ -68,7 +68,6 @@ def select_next_queue(self):
     def select_queue_by_hash_key(self, key):
         hash_object = hashlib.sha256(key.encode('utf-8'))
         hash_code = int.from_bytes(hash_object.digest(), byteorder='big')
-        print(f"hashcode: {hash_code}")
         return self.__message_queues[hash_code % len(self.__message_queues)]
 
     def all_queues(self):

python/rocketmq/v5/client/client.py

@@ -227,7 +227,6 @@ def __schedule_update_setting(self):
         asyncio.set_event_loop(self._rpc_channel_io_loop())
         while True:
             if self.__client_thread_task_enabled is True:
-                self.__sync_setting_scheduler_threading_event.wait(5)
                 logger.debug(f"{self.__str__()} run update setting in scheduler.")
                 try:
                     all_endpoints = self.__get_all_endpoints().values()
@@ -238,6 +237,7 @@ def __schedule_update_setting(self):
                     logger.error(
                         f"{self.__str__()} scheduler set setting raise exception: {e}"
                     )
+                self.__sync_setting_scheduler_threading_event.wait(300)
             else:
                 break
         logger.info(f"{self.__str__()} stop scheduler for update setting success.")
@@ -273,7 +273,7 @@ def __start_async_rpc_callback_handler(self):
                                                                  thread_name_prefix=f"client_callback_worker-{self.__client_id}")
             logger.info(f"{self.__str__()} start callback executor success. max_workers:{workers}")
         except Exception as e:
-            print(f"{self.__str__()} start async rpc callback raise exception: {e}")
+            logger.error(f"{self.__str__()} start async rpc callback raise exception: {e}")
             raise e
 
     @staticmethod

python/rocketmq/v5/client/metrics/client_metrics.py

@@ -28,6 +28,7 @@
 from rocketmq.v5.client.connection import RpcEndpoints
 from rocketmq.v5.log import logger
 from rocketmq.v5.model import HistogramEnum, MessageMetricType, MetricContext
+from rocketmq.v5.util import Signature
 
 
 class ClientMetrics:
@@ -142,6 +143,7 @@ def __meter_provider_start(self):
                 endpoint=self.__endpoints.__str__(),
                 insecure=True,
                 timeout=ClientMetrics.METRIC_EXPORTER_RPC_TIMEOUT,
+                headers=Signature.metadata(self.__client_configuration, self.__client_id)
             )
             # create a metric reader and set the export interval
             reader = PeriodicExportingMetricReader(

python/rocketmq/v5/consumer/simple_consumer.py

@@ -42,6 +42,7 @@ def __init__(
         consumer_group,
         subscription: dict = None,
         await_duration=20,
+        tls_enable=False
     ):
         if consumer_group is None or consumer_group.strip() == "":
             raise IllegalArgumentException("consumerGroup should not be null")
@@ -56,6 +57,7 @@ def __init__(
             client_configuration,
             None if subscription is None else subscription.keys(),
             ClientType.SIMPLE_CONSUMER,
+            tls_enable
         )
         self.__consumer_group = consumer_group
         self.__await_duration = await_duration  # long polling timeout, seconds
@@ -98,7 +100,7 @@ def unsubscribe(self, topic):
                 "unable to remove subscription because simple consumer is not running"
             )
 
-        if topic in self.__subscriptions:
+        if self.__subscriptions.contains(topic):
             self.__subscriptions.remove(topic)
             self._remove_unused_topic_route_data(topic)
 

python/rocketmq/v5/producer/producer.py

@@ -303,7 +303,6 @@ def shutdown(self):
     def __send(self, message: Message, topic_queue, attempt=1) -> SendReceipt:
         req = self.__send_req(message)
         send_context = self.client_metrics.send_before(message.topic)
-        print(f"{topic_queue}")
         send_message_future = self.rpc_client.send_message_async(
             topic_queue.endpoints,
             req,

python/rocketmq/v5/util/misc.py

@@ -29,7 +29,7 @@ class Misc:
     __OS_NAME = None
     TOPIC_PATTERN = compile(r"^[%a-zA-Z0-9_-]+$")
     CONSUMER_GROUP_PATTERN = compile(r"^[%a-zA-Z0-9_-]+$")
-    SDK_VERSION = "5.0.5"
+    SDK_VERSION = "5.0.6"
 
     @staticmethod
     def sdk_language():

python/setup.py

@@ -17,7 +17,7 @@
 
 setup(
     name='rocketmq-python-client',
-    version='5.0.5',
+    version='5.0.6',
     packages=find_packages(),
     install_requires=[
         "grpcio>=1.5.0",