# pip install tardis-client
from tardis_client import TardisClient, Channel
tardis_client = TardisClient(api_key="YOUR_API_KEY")
# replay method returns Async Generator
messages = tardis_client.replay(
filters=[Channel(name="marketDiff", symbols=[])]
# messages as provided by Binance DEX real-time stream
async for local_timestamp, message in messages: