update

Author: hhstore

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

@@ -15,15 +15,26 @@
 
 @group.task(trigger=Every(seconds=5))
 async def every():
-    msg = f"cron task: at {time.time()}"
-    logger.debug(f"Every 5 seconds, Publish msg to Nats, msg: {msg}")
+    msg = f"cron one: at {int(time.time())}"
+    logger.debug(f"cron one: pub msg: {msg}")
 
     await broker.publish(
         msg,
         subject="test-cron",
     )
 
 
+@group.task(trigger=Every(seconds=5))
+async def every():
+    msg = f"cron batch: at {int(time.time())}"
+    logger.debug(f"cron batch, pub msg: {msg}")
+
+    await broker.publish(
+        msg,
+        subject="test-cron2",
+    )
+
+
 @group.task(trigger=Every(weeks=50))
 def even_sync_works():
     logger.debug(f"synchronous task")

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

@@ -1,3 +1,5 @@
+import os
+
 import anyio
 from faststream import FastStream
 from faststream.nats import NatsBroker, PullSub
@@ -6,6 +8,11 @@
 
 host = "nats://localhost:4222"
 
+# logger file, 进程 id
+
+
+logger.add(f"tmp/nats_pub_{os.getpid()}.log", rotation="10 MB", retention="10 days")
+
 broker = NatsBroker(host)
 
 app = FastStream(broker)
@@ -20,13 +27,20 @@ async def to_batch(body: str, msg: NatsMessage):
     logger.debug(f"subscriber batch: msg: {msg}")
 
 
-@broker.subscriber("test-cron")
+@broker.subscriber("test-cron", "cron")
 async def to_cron(body: str, msg: NatsMessage):
     """
     TODO X: 定时任务
     """
-    logger.debug(f"subscriber batch: {body}")
-    logger.debug(f"subscriber batch: msg id: {msg.message_id}")
+    logger.debug(f"subscriber cron one: {body}, {msg.message_id}")
+
+
+@broker.subscriber("test-cron2")
+async def to_cron(body: str, msg: NatsMessage):
+    """
+    TODO X: 定时任务
+    """
+    logger.debug(f"subscriber cron batch: {body}, {msg.message_id}")
 
 
 @broker.subscriber("test-workers", "workers")