2025-05-30 20:33:56 +08:00
|
|
|
"""
|
|
|
|
|
Data collection and processing package for the Crypto Trading Bot Platform.
|
|
|
|
|
|
|
|
|
|
This package contains modules for collecting market data from various exchanges,
|
|
|
|
|
processing and validating the data, and storing it in the database.
|
|
|
|
|
"""
|
|
|
|
|
|
Implement data collection architecture with modular components
- Introduced a comprehensive data collection framework, including `CollectorServiceConfig`, `BaseDataCollector`, and `CollectorManager`, enhancing modularity and maintainability.
- Developed `CollectorFactory` for streamlined collector creation, promoting separation of concerns and improved configuration handling.
- Enhanced `DataCollectionService` to utilize the new architecture, ensuring robust error handling and logging practices.
- Added `TaskManager` for efficient management of asynchronous tasks, improving performance and resource management.
- Implemented health monitoring and auto-recovery features in `CollectorManager`, ensuring reliable operation of data collectors.
- Updated imports across the codebase to reflect the new structure, ensuring consistent access to components.
These changes significantly improve the architecture and maintainability of the data collection service, aligning with project standards for modularity, performance, and error handling.
2025-06-10 13:40:28 +08:00
|
|
|
from .collector.base_collector import (
|
2025-06-10 12:04:58 +08:00
|
|
|
BaseDataCollector, DataCollectorError
|
2025-05-30 20:33:56 +08:00
|
|
|
)
|
2025-06-10 12:04:58 +08:00
|
|
|
from .collector.collector_state_telemetry import CollectorStatus
|
|
|
|
|
from .common.ohlcv_data import OHLCVData, DataValidationError
|
2025-06-09 17:42:06 +08:00
|
|
|
from .common.data_types import DataType, MarketDataPoint
|
Implement data collection architecture with modular components
- Introduced a comprehensive data collection framework, including `CollectorServiceConfig`, `BaseDataCollector`, and `CollectorManager`, enhancing modularity and maintainability.
- Developed `CollectorFactory` for streamlined collector creation, promoting separation of concerns and improved configuration handling.
- Enhanced `DataCollectionService` to utilize the new architecture, ensuring robust error handling and logging practices.
- Added `TaskManager` for efficient management of asynchronous tasks, improving performance and resource management.
- Implemented health monitoring and auto-recovery features in `CollectorManager`, ensuring reliable operation of data collectors.
- Updated imports across the codebase to reflect the new structure, ensuring consistent access to components.
These changes significantly improve the architecture and maintainability of the data collection service, aligning with project standards for modularity, performance, and error handling.
2025-06-10 13:40:28 +08:00
|
|
|
from .collector.collector_manager import CollectorManager
|
|
|
|
|
from .collector.collector_types import ManagerStatus, CollectorConfig
|
2025-05-30 20:33:56 +08:00
|
|
|
|
|
|
|
|
__all__ = [
|
|
|
|
|
'BaseDataCollector',
|
|
|
|
|
'DataCollectorError',
|
|
|
|
|
'DataValidationError',
|
|
|
|
|
'DataType',
|
|
|
|
|
'CollectorStatus',
|
|
|
|
|
'MarketDataPoint',
|
|
|
|
|
'OHLCVData',
|
|
|
|
|
'CollectorManager',
|
|
|
|
|
'ManagerStatus',
|
|
|
|
|
'CollectorConfig'
|
|
|
|
|
]
|