main.py

from threading import Lock
import time
from ccapi import Logger, Session, Subscription
class MyLogger(Logger):
 def __init__(self):
 super().__init__()
 self._lock = Lock()
 def logMessage(self, severity: str, threadId: str, timeISO: str, fileName: str, lineNumber: str, message: str) -> None:
 self._lock.acquire()
 print(f'{threadId}: [{timeISO}] {{{fileName}:{lineNumber}}} {severity}{" " * 8}{message}')
 self._lock.release()
myLogger = MyLogger()
Logger.logger = myLogger
if __name__ == '__main__':
 session = Session()
 subscription = Subscription('coinbase', 'BTC-USD', 'MARKET_DEPTH')
 session.subscribe(subscription)
 time.sleep(10)
 session.stop()
 print('Bye')
 Logger.logger = None