From 61a874ca6f17bbc8aeecc2fa5c28f8fe6108dd1e Mon Sep 17 00:00:00 2001
From: mozzie <himozzie@foxmail.com>
Date: Thu, 14 Sep 2023 14:05:21 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20python=E5=8F=91=E5=B8=83=E6=B6=88?=
 =?UTF-8?q?=E6=81=AF=E5=88=B0nats-server?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 apps/services/alg/app.py | 11 ++++++++---
 1 file changed, 8 insertions(+), 3 deletions(-)

diff --git a/apps/services/alg/app.py b/apps/services/alg/app.py
index 8f4792d..cca06cd 100644
--- a/apps/services/alg/app.py
+++ b/apps/services/alg/app.py
@@ -2,9 +2,14 @@ from pynats2 import NATSClient
 from datetime import datetime,timedelta
 import json
 
+# nats-server配置信息
+NATS_PATTERN = "alg.test"
+NATS_SERVER = "nats://localhost:4222"
+
 def publish_to_nats():
+    timestamp = (datetime.utcnow() + timedelta(hours=8)).strftime("%Y-%m-%dT%H:%M:%S.%fZ")
     standardLog = {
-      "timestamp": (datetime.utcnow()+timedelta(hours=8)).strftime("%Y-%m-%dT%H:%M:%S.%fZ"),
+      "timestamp": timestamp,
       "level": 'INFO', # DEBUG、INFO、WARNING、ERROR、CRITICAL等级别
       "name": 'alg.slice',# 日志生产的模块、服务
       "message": "算法版本:$1,分割结果:$2",# 日志记录模板
@@ -13,8 +18,8 @@ def publish_to_nats():
         "$2": True
       },
     }
-    with NATSClient() as client:
-      client.publish("alg.test", payload=json.dumps(standardLog).encode('utf-8'))
+    with NATSClient(NATS_SERVER) as client:
+      client.publish(NATS_PATTERN, payload=json.dumps(standardLog).encode('utf-8'))
 
 if __name__ == '__main__':
     publish_to_nats()