Metadata-Version: 2.4
Name: dataflow-sdk
Version: 0.2.2
Summary: Add your description here
Requires-Python: >=3.13
Description-Content-Type: text/markdown
Requires-Dist: grpcio>=1.76.0
Requires-Dist: loguru>=0.7.3
Requires-Dist: orjson>=3.11.5
Requires-Dist: protobuf>=6.33.2
Requires-Dist: pydantic>=2.12.5

# dataflow-sdk

## Example

```python
from dataflow_sdk import save_items, Record
from dataflow_sdk.entity.model import CrawlType

result = {
    'name': 'xiaoming',
    "age": 25,
    "hello": "world",
    "world": 1121211
}

records = [Record(
    crawl_url=f"https://add.weee.tsinghua.edu.cn/{x}",
    crawl_type=CrawlType.ITEM,
    data=result,
    metadata={"name": "gage"},
) for x in range(10)]

save_items('Your Sink ID', records)
```
