# HG changeset patch # User drewp@bigasterisk.com # Date 1723356318 25200 # Node ID a640efa9fb01b1f22e1efdca67f4e6ccac2c4903 # Parent bc2a93b306e9883e764c07976423b49f398ac1de logging diff -r bc2a93b306e9 -r a640efa9fb01 mqtt_metrics.py --- a/mqtt_metrics.py Sat Aug 10 23:03:57 2024 -0700 +++ b/mqtt_metrics.py Sat Aug 10 23:05:18 2024 -0700 @@ -1,9 +1,9 @@ -import textwrap import asyncio import json import logging import os import re +import textwrap import time from typing import cast from weakref import WeakSet @@ -12,8 +12,8 @@ import uvicorn # v 2.0.0 from sse_starlette.sse import EventSourceResponse from starlette.applications import Starlette +from starlette.requests import Request from starlette.routing import Route -from starlette.requests import Request from starlette_exporter import PrometheusMiddleware, handle_metrics from convert import converters diff -r bc2a93b306e9 -r a640efa9fb01 victoriametrics_write.py --- a/victoriametrics_write.py Sat Aug 10 23:03:57 2024 -0700 +++ b/victoriametrics_write.py Sat Aug 10 23:05:18 2024 -0700 @@ -17,7 +17,7 @@ "values": [metricEvent['value']], "timestamps": [int(t * 1000)], } - log.info(promBody) + # log.info(promBody) req = httpx.post( self.agentImportUrl, json=promBody,