优化监控

Boris-code · Boris-code · commit c8497a35dcab · 2022-10-20T10:35:34.000+08:00
diff --git a/feapder/buffer/item_buffer.py b/feapder/buffer/item_buffer.py
@@ -402,10 +402,12 @@ def metric_datas(self, table, datas):
         @param datas: 数据 列表
         @return:
         """
-        metrics.emit_counter("total count", len(datas), classify=table)
+        total_count = 0
         for data in datas:
+            total_count += 1
             for k, v in data.items():
                 metrics.emit_counter(k, int(bool(v)), classify=table)
+        metrics.emit_counter("total count", total_count, classify=table)
 
     def close(self):
         # 调用pipeline的close方法
diff --git a/feapder/utils/metrics.py b/feapder/utils/metrics.py
@@ -295,10 +295,10 @@ def init(
     retention_policy=None,
     retention_policy_duration="180d",
     emit_interval=60,
-    batch_size=10,
+    batch_size=100,
     debug=False,
     use_udp=False,
-    timeout=10,
+    timeout=22,
     time_precision="s",
     ssl=False,
     **kwargs,
