light9 Changeset - 6eb1fcbad5f6

Changeset - 6eb1fcbad5f6

Parent rev.

Child rev.

[Not reviewed]

default

0 1 0

drewp@bigasterisk.com - 3 years ago 2022-05-25 06:32:19
drewp@bigasterisk.com

log/metrics cleanup

1 file changed with 4 insertions and 16 deletions:

light9/collector/service.py

0 comments (0 inline, 0 general)

light9/collector/service.py

➞

Show inline comments

@@ @@ -6,17 +6,14 @@ custom code for some attributes. @@
 Input can be over http or zmq.
 """
 import asyncio
 import functools
 import logging
 import os
 import traceback
 from typing import List
 from light9 import networking
 from light9.collector.collector import Collector
 from light9.collector.output import ArtnetDmx, DummyOutput, Output  # noqa
-from light9.collector.weblisteners import WebListeners, UiListener
+from light9.collector.weblisteners import UiListener, WebListeners
 from light9.namespaces import L9
 from light9.run_local import log
 from light9.zmqtransport import parseJsonMessage
@@ @@ -30,6 +27,8 @@ from starlette.types import Receive, Sco @@
 from starlette.websockets import WebSocket
 from starlette_exporter import PrometheusMiddleware, handle_metrics
 STAT_SETATTR = Summary('set_attr', 'setAttr calls')
 class Updates(WebSocketEndpoint, UiListener):
@@ @@ -55,25 +54,14 @@ class Updates(WebSocketEndpoint, UiListe @@
     pass
 STAT_SETATTR = Summary('set_attr', 'setAttr calls')
 async def PutAttrs(collector: Collector, request):
     with STAT_SETATTR.time():
     client, clientSession, settings, sendTime = parseJsonMessage(await request.body())
     collector.setAttrs(client, clientSession, settings, sendTime)
     return Response('', status_code=202)
 def main():
     # verbose = os.environ.get('VERBOSE', False)
     # logdmx = os.environ.get('LOGDMX', False)  # log all dmx sends
     log.setLevel(logging.DEBUG)
     # logging.getLogger('output').setLevel(logging.DEBUG)
     # logging.getLogger('output.allDmx').setLevel(logging.DEBUG if logdmx else logging.INFO)
     # logging.getLogger('colormath').setLevel(logging.INFO)
     graph = SyncedGraph(networking.rdfdb.url, "collector")
     try:

0 comments (0 inline, 0 general)