kuhl_haus.mdp package¶
kuhl_haus.mdp - Market data processing pipeline.
Provides real-time market data analysis, caching, and processing components built on WebSocket streams from Massive.com. Includes analyzers for stock and trade data, listener and processor components, and supporting data structures.
Subpackages¶
- kuhl_haus.mdp.analyzers package
- Submodules
- kuhl_haus.mdp.analyzers.analyzer module
AnalyzerOptionsAnalyzerOptions.redis_urlAnalyzerOptions.massive_api_keyAnalyzerOptions.finlight_api_keyAnalyzerOptions.kwargsAnalyzerOptions.redis_urlAnalyzerOptions.massive_api_keyAnalyzerOptions.finlight_api_keyAnalyzerOptions.kwargsAnalyzerOptions.new_rest_client()AnalyzerOptions.new_finlight_client()AnalyzerOptions.new_redis_client()AnalyzerOptions.__init__()
Analyzer
- kuhl_haus.mdp.analyzers.daily_range_analyzer module
- kuhl_haus.mdp.analyzers.finlight_data_analyzer module
- kuhl_haus.mdp.analyzers.leaderboard_analyzer module
LeaderboardAnalyzerLeaderboardAnalyzer.LEADERBOARD_TOP_VOLUMELeaderboardAnalyzer.LEADERBOARD_TOP_GAPPERSLeaderboardAnalyzer.LEADERBOARD_TOP_GAINERSLeaderboardAnalyzer.MARKET_DAY_KEYLeaderboardAnalyzer.MARKET_OPEN_RESET_KEYLeaderboardAnalyzer.PUBLISH_THROTTLE_KEYLeaderboardAnalyzer.__init__()LeaderboardAnalyzer.cacheLeaderboardAnalyzer.analyze_data()
- kuhl_haus.mdp.analyzers.massive_data_analyzer module
- kuhl_haus.mdp.analyzers.top_stocks module
- kuhl_haus.mdp.analyzers.top_trades_analyzer module
TopTradesAnalyzerTopTradesAnalyzer.TRADES_RECENT_PREFIXTopTradesAnalyzer.TRADES_STATS_PREFIXTopTradesAnalyzer.PUBLISH_THROTTLE_KEYTopTradesAnalyzer.TRADE_TTLTopTradesAnalyzer.TOP_TRADES_ALL_SYMBOLS_CACHE_KEYTopTradesAnalyzer.TOP_TRADES_ALL_SYMBOLS_CACHE_TTLTopTradesAnalyzer.TOP_TRADES_WIDGET_CACHE_KEYTopTradesAnalyzer.TOP_TRADES_WIDGET_CACHE_TTLTopTradesAnalyzer.MAX_TRADES_PER_SYMBOLTopTradesAnalyzer.PUBLISH_INTERVALTopTradesAnalyzer.__init__()TopTradesAnalyzer.cacheTopTradesAnalyzer.analyze_data()
- kuhl_haus.mdp.components package
- Submodules
- kuhl_haus.mdp.components.finlight_data_listener module
FinlightDataListenerFinlightDataListener.queryFinlightDataListener.tickersFinlightDataListener.sourcesFinlightDataListener.languageFinlightDataListener.__init__()FinlightDataListener.rawFinlightDataListener.include_entitiesFinlightDataListener.max_reconnectsFinlightDataListener.connection_statusFinlightDataListener.start()FinlightDataListener.stop()FinlightDataListener.restart()
- kuhl_haus.mdp.components.finlight_data_processor module
FinlightDataProcessorFinlightDataProcessor.__init__()FinlightDataProcessor.queue_nameFinlightDataProcessor.processedFinlightDataProcessor.processing_errorFinlightDataProcessor.errorFinlightDataProcessor.decoding_errorFinlightDataProcessor.publishedFinlightDataProcessor.mdq_connectedFinlightDataProcessor.mdc_connectedFinlightDataProcessor.connect()FinlightDataProcessor.start()FinlightDataProcessor.stop()
- kuhl_haus.mdp.components.finlight_data_queues module
FinlightDataQueuesFinlightDataQueues.connectionFinlightDataQueues.__init__()FinlightDataQueues.rabbitmq_urlFinlightDataQueues.queuesFinlightDataQueues.message_ttlFinlightDataQueues.publisher_confirmsFinlightDataQueues.channelsFinlightDataQueues.exchangesFinlightDataQueues.connection_statusFinlightDataQueues.connect()FinlightDataQueues.handle_message()FinlightDataQueues.shutdown()FinlightDataQueues.setup_queues()
- kuhl_haus.mdp.components.finlight_simple_listener module
- kuhl_haus.mdp.components.market_data_cache module
- kuhl_haus.mdp.components.market_data_scanner module
MarketDataScannerMarketDataScanner.decoding_errorMarketDataScanner.droppedMarketDataScanner.errorMarketDataScanner.__init__()MarketDataScanner.mdc_connectedMarketDataScanner.restartsMarketDataScanner.processedMarketDataScanner.start()MarketDataScanner.stop()MarketDataScanner.connect()MarketDataScanner.restart()MarketDataScanner.get_cache()MarketDataScanner.cache_result()
- kuhl_haus.mdp.components.massive_data_listener module
MassiveDataListenerMassiveDataListener.ws_connectionMassiveDataListener.ws_coroutineMassiveDataListener.feedMassiveDataListener.marketMassiveDataListener.subscriptionsMassiveDataListener.__init__()MassiveDataListener.rawMassiveDataListener.verboseMassiveDataListener.max_reconnectsMassiveDataListener.secureMassiveDataListener.connection_statusMassiveDataListener.start()MassiveDataListener.stop()MassiveDataListener.restart()MassiveDataListener.market_is_open()MassiveDataListener.async_task()
- kuhl_haus.mdp.components.massive_data_processor module
MassiveDataProcessorMassiveDataProcessor.__init__()MassiveDataProcessor.queue_nameMassiveDataProcessor.processedMassiveDataProcessor.processing_errorMassiveDataProcessor.errorMassiveDataProcessor.decoding_errorMassiveDataProcessor.publishedMassiveDataProcessor.mdq_connectedMassiveDataProcessor.mdc_connectedMassiveDataProcessor.connect()MassiveDataProcessor.start()MassiveDataProcessor.stop()
- kuhl_haus.mdp.components.massive_data_queues module
MassiveDataQueuesMassiveDataQueues.connectionMassiveDataQueues.__init__()MassiveDataQueues.rabbitmq_urlMassiveDataQueues.queuesMassiveDataQueues.message_ttlMassiveDataQueues.publisher_confirmsMassiveDataQueues.channelsMassiveDataQueues.exchangesMassiveDataQueues.connection_statusMassiveDataQueues.connect()MassiveDataQueues.handle_messages()MassiveDataQueues.shutdown()MassiveDataQueues.setup_queues()
- kuhl_haus.mdp.components.widget_data_service module
- kuhl_haus.mdp.data package
- Submodules
- kuhl_haus.mdp.data.market_data_analyzer_result module
- kuhl_haus.mdp.data.top_stocks_cache_item module
TopStocksCacheItemTopStocksCacheItem.day_start_timeTopStocksCacheItem.symbol_data_cacheTopStocksCacheItem.top_volume_mapTopStocksCacheItem.top_gappers_mapTopStocksCacheItem.top_gainers_mapTopStocksCacheItem.to_dict()TopStocksCacheItem.top_volume()TopStocksCacheItem.top_gappers()TopStocksCacheItem.top_gainers()TopStocksCacheItem.__init__()
- kuhl_haus.mdp.enum package
- Submodules
- kuhl_haus.mdp.enum.constants module
- kuhl_haus.mdp.enum.finlight_data_cache module
- kuhl_haus.mdp.enum.finlight_data_queue module
- kuhl_haus.mdp.enum.market_data_cache_keys module
MarketDataCacheKeysMarketDataCacheKeys.AGGREGATEMarketDataCacheKeys.TRADESMarketDataCacheKeys.QUOTESMarketDataCacheKeys.HALTSMarketDataCacheKeys.UNKNOWNMarketDataCacheKeys.LEADERBOARD_TOP_VOLUMEMarketDataCacheKeys.LEADERBOARD_TOP_GAPPERSMarketDataCacheKeys.LEADERBOARD_TOP_GAINERSMarketDataCacheKeys.LEADERBOARD_PUBLISH_THROTTLE_KEYMarketDataCacheKeys.LEADERBOARD_MARKET_DAY_KEYMarketDataCacheKeys.LEADERBOARD_MARKET_OPEN_RESET_KEYMarketDataCacheKeys.TOP_TRADES_RECENT_PREFIXMarketDataCacheKeys.TOP_TRADES_RECENT_SCANMarketDataCacheKeys.TOP_TRADES_STATS_PREFIXMarketDataCacheKeys.TOP_TRADES_LAST_PUBLISH_KEYMarketDataCacheKeys.TOP_TRADES_WIDGET_CACHE_KEYMarketDataCacheKeys.TOP_TRADES_ALL_SYMBOLS_CACHE_KEYMarketDataCacheKeys.TICKER_SNAPSHOTSMarketDataCacheKeys.TICKER_AVG_VOLUMEMarketDataCacheKeys.TICKER_FREE_FLOATMarketDataCacheKeys.TICKER_SNAPSHOT_LOCKMarketDataCacheKeys.TICKER_AVG_VOLUME_LOCKMarketDataCacheKeys.TICKER_FREE_FLOAT_LOCKMarketDataCacheKeys.DAILY_AGGREGATESMarketDataCacheKeys.TOP_TRADES_SCANNERMarketDataCacheKeys.TOP_GAINERS_SCANNERMarketDataCacheKeys.TOP_GAPPERS_SCANNERMarketDataCacheKeys.TOP_STOCKS_SCANNERMarketDataCacheKeys.TOP_VOLUME_SCANNER
- kuhl_haus.mdp.enum.market_data_cache_ttl module
MarketDataCacheTTLMarketDataCacheTTL.NEGATIVE_CACHE_THROTTLEMarketDataCacheTTL.NEGATIVE_CACHE_SESSIONMarketDataCacheTTL.AGGREGATEMarketDataCacheTTL.HALTSMarketDataCacheTTL.QUOTESMarketDataCacheTTL.TRADESMarketDataCacheTTL.UNKNOWNMarketDataCacheTTL.TICKER_AVG_VOLUMEMarketDataCacheTTL.TICKER_FREE_FLOATMarketDataCacheTTL.TICKER_SNAPSHOTSMarketDataCacheTTL.TICKER_SNAPSHOT_LOCKMarketDataCacheTTL.TICKER_AVG_VOLUME_LOCKMarketDataCacheTTL.TICKER_FREE_FLOAT_LOCKMarketDataCacheTTL.LEADERBOARD_ANALYZERMarketDataCacheTTL.LEADERBOARD_TOP_VOLUMEMarketDataCacheTTL.LEADERBOARD_TOP_GAPPERSMarketDataCacheTTL.LEADERBOARD_TOP_GAINERSMarketDataCacheTTL.TOP_TRADES_TRADE_TTLMarketDataCacheTTL.TOP_TRADES_WIDGET_CACHE_TTLMarketDataCacheTTL.TOP_TRADES_ALL_SYMBOLS_CACHE_TTLMarketDataCacheTTL.QUOTEMarketDataCacheTTL.TOP_STOCKS_SCANNERMarketDataCacheTTL.TOP_VOLUME_SCANNERMarketDataCacheTTL.TOP_GAINERS_SCANNERMarketDataCacheTTL.TOP_GAPPERS_SCANNERMarketDataCacheTTL.NEWS_FEED_LATESTMarketDataCacheTTL.NEWS_TICKER
__getattr__()
- kuhl_haus.mdp.enum.market_data_pubsub_keys module
MarketDataPubSubKeysMarketDataPubSubKeys.TOP_10_LISTS_SCANNERMarketDataPubSubKeys.TOP_TRADES_SCANNER_ONE_HOURMarketDataPubSubKeys.TOP_TRADES_SCANNER_FIVE_MINUTESMarketDataPubSubKeys.TOP_TRADES_SCANNER_ONE_MINUTEMarketDataPubSubKeys.QUOTEMarketDataPubSubKeys.TOP_GAINERS_SCANNERMarketDataPubSubKeys.TOP_GAPPERS_SCANNERMarketDataPubSubKeys.TOP_VOLUME_SCANNERMarketDataPubSubKeys.NEWS_FEED_LATESTMarketDataPubSubKeys.NEWS_TICKER
- kuhl_haus.mdp.enum.market_data_scanner_names module
- kuhl_haus.mdp.enum.market_status_value module
- kuhl_haus.mdp.enum.massive_data_queue module
- kuhl_haus.mdp.enum.widget_data_cache_keys module
WidgetDataCacheKeysWidgetDataCacheKeys.TOP_10_LISTS_SCANNERWidgetDataCacheKeys.TOP_TRADES_SCANNER_ONE_HOURWidgetDataCacheKeys.TOP_TRADES_SCANNER_FIVE_MINUTESWidgetDataCacheKeys.TOP_TRADES_SCANNER_ONE_MINUTEWidgetDataCacheKeys.TOP_TRADES_WIDGET_CACHE_KEYWidgetDataCacheKeys.TOP_TRADES_ALL_SYMBOLS_CACHE_KEYWidgetDataCacheKeys.QUOTEWidgetDataCacheKeys.TOP_GAINERS_SCANNERWidgetDataCacheKeys.TOP_GAPPERS_SCANNERWidgetDataCacheKeys.TOP_VOLUME_SCANNERWidgetDataCacheKeys.TOP_TRADES_SCANNERWidgetDataCacheKeys.TOP_STOCKS_SCANNERWidgetDataCacheKeys.NEWS_FEED_LATESTWidgetDataCacheKeys.NEWS_TICKERWidgetDataCacheKeys.DAILY_RANGEWidgetDataCacheKeys.DAILY_RANGE_HOD_ALERTWidgetDataCacheKeys.DAILY_RANGE_LOD_ALERT
- kuhl_haus.mdp.enum.widget_data_cache_limits module
- kuhl_haus.mdp.enum.widget_data_cache_ttl module
WidgetDataCacheTTLWidgetDataCacheTTL.QUOTEWidgetDataCacheTTL.TOP_STOCKS_SCANNERWidgetDataCacheTTL.TOP_VOLUME_SCANNERWidgetDataCacheTTL.TOP_GAINERS_SCANNERWidgetDataCacheTTL.TOP_GAPPERS_SCANNERWidgetDataCacheTTL.TOP_TRADES_WIDGET_CACHE_TTLWidgetDataCacheTTL.TOP_TRADES_ALL_SYMBOLS_CACHE_TTLWidgetDataCacheTTL.NEWS_FEED_LATESTWidgetDataCacheTTL.NEWS_TICKERWidgetDataCacheTTL.DAILY_RANGEWidgetDataCacheTTL.DAILY_RANGE_ALERT
- kuhl_haus.mdp.exceptions package
- kuhl_haus.mdp.helpers package
- Submodules
- kuhl_haus.mdp.helpers.observability module
- kuhl_haus.mdp.helpers.process_manager module
- kuhl_haus.mdp.helpers.queue_name_resolver module
- kuhl_haus.mdp.helpers.serde module
- kuhl_haus.mdp.helpers.structured_logging module
- kuhl_haus.mdp.helpers.utils module
- kuhl_haus.mdp.helpers.web_socket_message_serde module
WebSocketMessageSerdeWebSocketMessageSerde.serialize()WebSocketMessageSerde.to_dict()WebSocketMessageSerde.deserialize()WebSocketMessageSerde.decode_limit_up_limit_down()WebSocketMessageSerde.serialize_limit_up_limit_down()WebSocketMessageSerde.decode_equity_agg()WebSocketMessageSerde.serialize_equity_agg()WebSocketMessageSerde.decode_equity_trade()WebSocketMessageSerde.serialize_equity_trade()WebSocketMessageSerde.decode_equity_quote()WebSocketMessageSerde.serialize_equity_quote()