[Logs] disable very verbose trading logs by default

Author: Guillaume De Saint Martin

octobot/constants.py

@@ -108,7 +108,7 @@
 
 # logs
 LOGS_FOLDER = "logs"
-ENV_ENABLE_DEBUG_LOGS = "ENABLE_DEBUG_LOGS"
+ENV_TRADING_ENABLE_DEBUG_LOGS = os_util.parse_boolean_environment_var("ENV_TRADING_ENABLE_DEBUG_LOGS", "False")
 
 # errors
 ERRORS_URL = os.getenv("ERRORS_OCTOBOT_ONLINE_URL", "https://errors.octobot.online/")

octobot/logger.py

@@ -93,30 +93,10 @@ def _load_logger_config():
 
 
 async def init_exchange_chan_logger(exchange_id):
-    await exchanges_channel.get_chan(channels_name.OctoBotTradingChannelsName.TICKER_CHANNEL.value,
-                                     exchange_id).new_consumer(
-        ticker_callback, priority_level=LOGGER_PRIORITY_LEVEL
-    )
-    await exchanges_channel.get_chan(channels_name.OctoBotTradingChannelsName.MINI_TICKER_CHANNEL.value,
-                                     exchange_id).new_consumer(
-        mini_ticker_callback, priority_level=LOGGER_PRIORITY_LEVEL
-    )
     await exchanges_channel.get_chan(channels_name.OctoBotTradingChannelsName.RECENT_TRADES_CHANNEL.value,
                                      exchange_id).new_consumer(
         recent_trades_callback, priority_level=LOGGER_PRIORITY_LEVEL
     )
-    await exchanges_channel.get_chan(channels_name.OctoBotTradingChannelsName.ORDER_BOOK_CHANNEL.value,
-                                     exchange_id).new_consumer(
-        order_book_callback, priority_level=LOGGER_PRIORITY_LEVEL
-    )
-    await exchanges_channel.get_chan(channels_name.OctoBotTradingChannelsName.ORDER_BOOK_TICKER_CHANNEL.value,
-                                     exchange_id).new_consumer(
-        order_book_ticker_callback, priority_level=LOGGER_PRIORITY_LEVEL
-    )
-    await exchanges_channel.get_chan(channels_name.OctoBotTradingChannelsName.KLINE_CHANNEL.value,
-                                     exchange_id).new_consumer(
-        kline_callback, priority_level=LOGGER_PRIORITY_LEVEL
-    )
     await exchanges_channel.get_chan(channels_name.OctoBotTradingChannelsName.OHLCV_CHANNEL.value,
                                      exchange_id).new_consumer(
         ohlcv_callback, priority_level=LOGGER_PRIORITY_LEVEL
@@ -125,18 +105,10 @@ async def init_exchange_chan_logger(exchange_id):
                                      exchange_id).new_consumer(
         funding_callback, priority_level=LOGGER_PRIORITY_LEVEL
     )
-    await exchanges_channel.get_chan(channels_name.OctoBotTradingChannelsName.MARK_PRICE_CHANNEL.value,
-                                     exchange_id).new_consumer(
-        mark_price_callback, priority_level=LOGGER_PRIORITY_LEVEL
-    )
     await exchanges_channel.get_chan(channels_name.OctoBotTradingChannelsName.BALANCE_CHANNEL.value,
                                      exchange_id).new_consumer(
         balance_callback, priority_level=channel_enums.ChannelConsumerPriorityLevels.MEDIUM.value
     )
-    await exchanges_channel.get_chan(channels_name.OctoBotTradingChannelsName.BALANCE_PROFITABILITY_CHANNEL.value,
-                                     exchange_id).new_consumer(
-        balance_profitability_callback, priority_level=channel_enums.ChannelConsumerPriorityLevels.MEDIUM.value
-    )
     await exchanges_channel.get_chan(channels_name.OctoBotTradingChannelsName.TRADES_CHANNEL.value,
                                      exchange_id).new_consumer(
         trades_callback, priority_level=channel_enums.ChannelConsumerPriorityLevels.MEDIUM.value
@@ -153,6 +125,36 @@ async def init_exchange_chan_logger(exchange_id):
                                      exchange_id).new_consumer(
         orders_callback, priority_level=channel_enums.ChannelConsumerPriorityLevels.MEDIUM.value
     )
+    # secondary logs, very verbose on websockets
+    if constants.ENV_TRADING_ENABLE_DEBUG_LOGS:
+        await exchanges_channel.get_chan(channels_name.OctoBotTradingChannelsName.TICKER_CHANNEL.value,
+                                         exchange_id).new_consumer(
+            ticker_callback, priority_level=LOGGER_PRIORITY_LEVEL
+        )
+        await exchanges_channel.get_chan(channels_name.OctoBotTradingChannelsName.MINI_TICKER_CHANNEL.value,
+                                         exchange_id).new_consumer(
+            mini_ticker_callback, priority_level=LOGGER_PRIORITY_LEVEL
+        )
+        await exchanges_channel.get_chan(channels_name.OctoBotTradingChannelsName.ORDER_BOOK_CHANNEL.value,
+                                         exchange_id).new_consumer(
+            order_book_callback, priority_level=LOGGER_PRIORITY_LEVEL
+        )
+        await exchanges_channel.get_chan(channels_name.OctoBotTradingChannelsName.ORDER_BOOK_TICKER_CHANNEL.value,
+                                         exchange_id).new_consumer(
+            order_book_ticker_callback, priority_level=LOGGER_PRIORITY_LEVEL
+        )
+        await exchanges_channel.get_chan(channels_name.OctoBotTradingChannelsName.KLINE_CHANNEL.value,
+                                         exchange_id).new_consumer(
+            kline_callback, priority_level=LOGGER_PRIORITY_LEVEL
+        )
+        await exchanges_channel.get_chan(channels_name.OctoBotTradingChannelsName.MARK_PRICE_CHANNEL.value,
+                                         exchange_id).new_consumer(
+            mark_price_callback, priority_level=LOGGER_PRIORITY_LEVEL
+        )
+        await exchanges_channel.get_chan(channels_name.OctoBotTradingChannelsName.BALANCE_PROFITABILITY_CHANNEL.value,
+                                         exchange_id).new_consumer(
+            balance_profitability_callback, priority_level=channel_enums.ChannelConsumerPriorityLevels.MEDIUM.value
+        )
 
 
 async def init_evaluator_chan_logger(matrix_id: str):