dev

plot/refill/ChannelWriter.py

@@ -123,7 +123,7 @@ class ChannelWriter(DataWriteStream):
     def path_pos(self, chname, time, spec, card_type):
         today = day_stamp(time)
         path = f'/{self._version}/{today}/{chname}/{card_type}/{spec}'
-        log.debug("%s,%s", 'ChannelWriter', path)
+        # log.debug("%s,%s", 'ChannelWriter', path)
 
         dset = self._data_set(path=path)
         return dset, time - today

plot/refill/MerchantWriter.py

@@ -124,7 +124,7 @@ class MerchantWriter(DataWriteStream):
         today = day_stamp(time)
         path = f'/{self._version}/{today}/{mchid}/{card_type}/{spec}'
 
-        log.debug("%s,%s", 'MerchantWriter', path)
+        # log.debug("%s,%s", 'MerchantWriter', path)
         dset = self._data_set(path=path)
         return dset, time - today
 

plot/refill/NetchkWriter.py

@@ -97,7 +97,7 @@ class NetchkWriter(DataWriteStream):
     def path_pos(self, chname, time):
         today = day_stamp(time)
         path = f'/{self._version}/{today}/{chname}'
-        log.debug("%s,%s", 'NetchkWriter', path)
+        # log.debug("%s,%s", 'NetchkWriter', path)
 
         dset = self._data_set(path=path)
         return dset, time - today

plot/refill/WriterConsumer.py

@@ -17,7 +17,7 @@ class WriterConsumer(Thread):
     def run(self):
         while True:
             size = self._messages.qsize()
-            log.debug("%s messages size=%d", self._name, size)
+            # log.debug("%s messages size=%d", self._name, size)
             if size > self._max_threshold:
                 self._batch()
             else: