update

Author: hhstore

packages/try/try-faststream/src/try_faststream/run_pub_cron.py

@@ -13,7 +13,7 @@
 group = Group()
 
 
-@group.task(trigger=Every(seconds=5))
+@group.task(trigger=Every(seconds=10))
 async def every():
     msg = f"cron one: at {int(time.time())}"
     logger.debug(f"cron one: pub msg: {msg}")
@@ -24,7 +24,7 @@ async def every():
     )
 
 
-@group.task(trigger=Every(seconds=5))
+@group.task(trigger=Every(seconds=15))
 async def every():
     msg = f"cron batch: at {int(time.time())}"
     logger.debug(f"cron batch, pub msg: {msg}")

packages/try/try-faststream/src/try_faststream/run_sub.py

@@ -24,15 +24,15 @@ async def to_batch(body: str, msg: NatsMessage):
     TODO X: 一条消息, 如果有多个实例, 会多次消费(重复消费)
     """
     logger.debug(f"subscriber batch: {body}")
-    logger.debug(f"subscriber batch: msg: {msg}")
+    logger.debug(f"subscriber batch: msg: {msg.correlation_id}")
 
 
 @broker.subscriber("test-cron", "cron")
 async def to_cron(body: str, msg: NatsMessage):
     """
     TODO X: 定时任务
     """
-    logger.debug(f"subscriber cron one: {body}, {msg.message_id}")
+    logger.debug(f"subscriber cron one: {body}, {msg.correlation_id}")
 
 
 @broker.subscriber("test-cron2")