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.3.tar.gz (49.0 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

data_stream_kit-0.0.3-py3-none-any.whl (65.0 kB view details)

Uploaded Python 3

File details

Details for the file data-stream-kit-0.0.3.tar.gz.

File metadata

  • Download URL: data-stream-kit-0.0.3.tar.gz
  • Upload date:
  • Size: 49.0 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/4.0.2 CPython/3.11.5

File hashes

Hashes for data-stream-kit-0.0.3.tar.gz
Algorithm Hash digest
SHA256 a53e86aea826a599dc78706525f4bf7fd348d4cf86ff45881d45441f57e9e94d
MD5 e813a5deaf02ff5756bb742ecab4ab64
BLAKE2b-256 dc9824c509f9e66ad0f6789c5b2f41e3ab68620e106e6e2610c7c4d75cd5c654

See more details on using hashes here.

File details

Details for the file data_stream_kit-0.0.3-py3-none-any.whl.

File metadata

File hashes

Hashes for data_stream_kit-0.0.3-py3-none-any.whl
Algorithm Hash digest
SHA256 a719a895b0675a73b3b9736e621af24091984d8025cfc701df8bac4c40066832
MD5 6c2b2aeb9becc6e811d85426291fbf74
BLAKE2b-256 af0cac2e8471d9df0de5aad4040be4fb1cdc4142ed4744c3d355a54cbeb32a64

See more details on using hashes here.

Supported by

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