Skip to main content

数据处理工具

Project description

### data-stream-kit

数据流处理工具包

主要功能:

  1. data_stream_kit.sqla_decorator: sqlalchemy的高度封装,使用线程数据,实现修饰器的方式调用session。

  2. data_stream_kit.sqla_asyncio: 简单封装了异步sqlalchemy的session。

  3. data_stream_kit.kafka_lib: 封装了kafka的生产者KafkaProducer和消费者KafkaConsumer。

  4. data_stream_kit.kafka_asyncio: 异步的kafka生产者AIOProducer和消费者AIOConsumer。

打包流程:

  1. 生成wheel文件和源代码压缩包:python setup.py sdist bdist_wheel

  2. 上传生成的文件:twine upload dist/*。之后输入账号密码。

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

data-stream-kit-0.0.1.tar.gz (49.1 kB view hashes)

Uploaded Source

Built Distribution

data_stream_kit-0.0.1-py3-none-any.whl (65.0 kB view hashes)

Uploaded Python 3

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page