[+] add basic entry point

This commit is contained in:
Siarhei Siniak 2025-07-08 13:17:13 +03:00
parent 38c0b9ba87
commit 9aec75cdd7

@ -0,0 +1,27 @@
import asyncio
import os
from ..tickers_retrieval.emcont import Emcont
from ..tickers.models import Ticker
import sqlalchemy.ext.asyncio
from typing import Any
async def run() -> None:
engine = sqlalchemy.ext.asyncio.create_async_engine(
os.environ['DB_URL']
)
async_session = sqlalchemy.ext.asyncio.async_sessionmaker(
engine
)
async def store_cb(rates: Any, timestamp: Any, session: Any) -> None:
print(rates, timestamp.isoformat())
await Emcont.worker(
only_symbols={'EURUSD', 'USDJPY', 'GBPUSD', 'AUDUSD', 'USDCAD'},
session=async_session,
store_cb=store_cb
)
if __name__ == '__main__':
asyncio.run(run())