# 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(
exchange="gate-io-futures",
filters=[Channel(name="order_book", symbols=["BTC_USDT"])]
# messages as provided by Gate.io Futures real-time stream
async for local_timestamp, message in messages: