vi bSrSSKJr SSKJr SSKJr SSKJr "SS\5r "SS 5r g ) zStreaming ingestion service for Kafka/Pub-Sub style data ingestion. Provides an asynchronous pipeline for consuming racing data from message brokers, enabling near-real-time rating updates. ) annotations)Callable)StrEnum)Anyc(\rSrSrSrSrSrSrSrSr g) MessageSourcez$Supported streaming message sources.kafka redis_pubsubrabbitmqwebhookN) __name__ __module__ __qualname____firstlineno____doc__KAFKA REDIS_PUBSUBRABBITMQWEBHOOK__static_attributes__r>/root/tipsharks/tipsharks-elo-api/packages/ingest/streaming.pyrrs. E!LHGrrc\rSrSrSr\R S4S SjjrS SjrS Sjr S Sjr SSjr \ SS j5r S rg)StreamingIngestionServicezIngests racing data via streaming message brokers. Supports consuming race results, runner updates, and meeting information from Kafka, Redis Pub/Sub, or other brokers for near-real-time processing. Nc`[U5UlU=(d 0Ul0UlSUlg)zInitialize the streaming ingestion service. Args: source: Message source type. config: Source-specific configuration dict (e.g., bootstrap_servers, topic, group_id for Kafka). FN)rsourceconfig _handlers_running)selfrr s r__init__"StreamingIngestionService.__init__s)$F+ l 46 rcZURRU/5RU5 g)zRegister a handler function for a given topic. Args: topic: Message topic/channel to subscribe to. handler: Callable that accepts a message payload dict. N)r! setdefaultappend)r#topichandlers rregister_handler*StreamingIngestionService.register_handler0s# !!%,33GrHs0 #$GEEr