메뉴
Maintain live market data feed adapters in feeds/ with focus on Zerodha websocket integration and normalized tick payloads. Use when adding new feed providers, normalizing tick schema, or debugging live tick ingestion issues.
Codex 또는 Claude로 설치 이 Prompt를 복사해 Codex, Claude 또는 다른 어시스턴트에 붙여 넣으면 Skill 페이지를 검토하고 설치를 진행할 수 있습니다.
SOC 직업 분류 기준
Analyze and evolve the overall architecture of next-gen-algo-trading-bot across ingestion, aggregation, strategy execution, storage, APIs, and UI layers. Use when making cross-module changes, debugging data flow breaks between modules, planning new features, or assessing tradeoffs and risk before refactors.
Implement and maintain broker connectivity for Zerodha in brokers/ including auth, session retry behavior, order/position APIs, and historical data sync helpers. Use when touching login flow, order execution, broker resilience, or market data backfill behavior.
Operate and extend the Typer CLI entrypoints in cli/main.py for engine start/stop and timeframe worker execution. Use when adding commands, wiring new modules into runtime startup, or debugging startup/config/env failures.
Manage and validate runtime configuration schemas and YAML files under config/ plus root config.yaml for the trading engine. Use when adding config fields, fixing env interpolation, or resolving mismatches between configured and supported timeframes/indicators.
Implement and maintain the core orchestration and compute pipeline in core/ including base interfaces, engine actors, aggregation, timeframe generation, and indicator generation. Use when changing runtime data flow, worker behavior, or strategy execution mechanics.
Maintain local operator dashboards in dashboard/ using Streamlit and Dash for candle inspection and indicator visualization. Use when improving manual observability, chart behavior, or live diagnostics from parquet-backed data.
| name | ngat-feeds |
| description | Maintain live market data feed adapters in feeds/ with focus on Zerodha websocket integration and normalized tick payloads. Use when adding new feed providers, normalizing tick schema, or debugging live tick ingestion issues. |
Own realtime data ingress semantics from broker websocket streams into internal candle-ready events.
feeds/zerodha_ws.py: ZerodhaWebSocketFeed implementing BaseFeed.core/base.py::BaseFeed: contract for subscribe/unsubscribe/close behavior.exchange_timestamp missing/null in ticks.astimezone(pytz.utc)).