Metadata-Version: 2.4
Name: dangdatastream
Version: 0.1.0
Summary: Producer–bus–consumer reference data stream library (Finnhub + Kafka) for Trade_service.
Author-email: nndang27 <elnino27012002@gmail.com>
License-Expression: MIT
Project-URL: Source Code, https://github.com/nndang27/dangdatastream
Project-URL: Bug Tracker, https://github.com/nndang27/dangdatastream/issues
Keywords: market-data,streaming,kafka,finnhub,trading,finance
Classifier: Development Status :: 3 - Alpha
Classifier: Intended Audience :: Developers
Classifier: Intended Audience :: Financial and Insurance Industry
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.10
Classifier: Programming Language :: Python :: 3.11
Classifier: Programming Language :: Python :: 3.12
Classifier: Topic :: Office/Business :: Financial
Classifier: Topic :: Software Development :: Libraries :: Python Modules
Requires-Python: >=3.10
Description-Content-Type: text/markdown
License-File: LICENSE
Requires-Dist: aiohttp>=3.9
Requires-Dist: confluent-kafka>=2.4
Requires-Dist: pydantic>=2.0
Provides-Extra: dotenv
Requires-Dist: python-dotenv>=1.0; extra == "dotenv"
Provides-Extra: providers
Requires-Dist: yfinance>=0.2.40; extra == "providers"
Requires-Dist: pandas>=2.0; extra == "providers"
Provides-Extra: dev
Requires-Dist: pytest>=8.0; extra == "dev"
Dynamic: license-file

## dangdatastream

`dangdatastream` is a small reference implementation of a **producer → bus → consumer**
streaming architecture for market data, designed to plug into the `Trade_service` codebase.

### Features (current)
- Finnhub real-time SOURCE adapter (WS + polling)
- Kafka bus abstraction (high-throughput producer tuning + at-least-once consumer + DLQ)
- Minimal producer (SOURCE → Kafka)
- Minimal consumer (Kafka → stdout)

### Install (editable dev)

From this folder:

```bash
pip install -e ".[dotenv,providers,dev]"
```

### Configure

Copy `.env.example` to `.env` and fill `FINNHUB_API_KEY`.

### Run

Interactive CLI:

```bash
dangdatastream
```

Producer:

```bash
dangdatastream-producer-finnhub
```

Consumer:

```bash
dangdatastream-consumer-print
```

