trell-data-pipeline

View on PyPIReverse Dependencies (0)

0.4.11 trell_data_pipeline-0.4.11-py2.py3-none-any.whl

Wheel Details

Project: trell-data-pipeline
Version: 0.4.11
Filename: trell_data_pipeline-0.4.11-py2.py3-none-any.whl
Download: [link]
Size: 19235
MD5: 1654db436bf653c9d4844346a8b50604
SHA256: ef69479e962b2b5998e46fde751001bff987d777c5446388e12cc81e099f3eee
Uploaded: 2020-03-06 08:54:52 +0000

dist-info

METADATA

Metadata-Version: 2.1
Name: trell-data-pipeline
Version: 0.4.11
Summary: Pipes various ingress streams to another egress stream. I.e. MQTT -> Kafka
Author: Johan Frisell
Author-Email: johan[at]trell.se
Home-Page: https://github.com/frisellcpl/trell-data-pipeline
Classifier: Intended Audience :: Developers
Classifier: Topic :: Utilities
Classifier: License :: Public Domain
Classifier: Natural Language :: English
Classifier: Operating System :: OS Independent
Classifier: Programming Language :: Python :: 3.6
Classifier: Programming Language :: Python :: 3.7
Classifier: Programming Language :: Python :: 3.8
Requires-Dist: aiokafka (==0.5.2)
Requires-Dist: asyncpg (==0.20.1)
Requires-Dist: PyYAML (==5.3)
Requires-Dist: gmqtt (==0.5.5)
Requires-Dist: jsonschema (==3.2.0)
Requires-Dist: pytest (==2.9.2); extra == "dev"
Provides-Extra: dev
[No description]

WHEEL

Wheel-Version: 1.0
Generator: bdist_wheel (0.33.6)
Root-Is-Purelib: true
Tag: py2-none-any
Tag: py3-none-any

RECORD

Path Digest Size
pipeline/__init__.py sha256=QONm0wAty5kr3fbcBPBufTI2cW63CTlhc2LMimHpIMQ 2245
pipeline/cli.py sha256=0X-7KSApIjhXkQwyeDsbLs61idKPB6askW6RbHPthJY 2158
pipeline/cli_args.py sha256=Jfxw5xur8jcnLVWdS7Qcdskh0cifYSKBec76jNvugvo 4289
pipeline/config.py sha256=xTUh3-zBJtjQkeudHzq88ywrvO-Anz5_LY9gWZZ_yDo 998
pipeline/decoders.py sha256=4DbiVSllJUxg3fGdH4DRJo43TOceBtSnSohu-lbRU-o 8012
pipeline/main.py sha256=PCFSAYGpghQH-jf4lT1ZEgEaWpr04wXZNQB7yrWGwLw 1236
pipeline/mqtt.py sha256=LVBo0tAvKpv7ApkHBlouD-O4v62bSeQb6TrRv4dr80I 2416
pipeline/producers.py sha256=KWhcBXRKsD1XLGaBpcWyBOPWaxgzWrAGfxcitgH-aQ8 2137
pipeline/settings.py sha256=w_tQVP2J_ViOlOG9Fcerwl9CHWGTcmQ-nxFWHVzV-ms 423
pipeline/types.py sha256=331Cf1MVV3kEnoSASCNXsrZSfXWdQ4bGFoKNUzdEZEk 45
pipeline/clients/__init__.py sha256=cI9fzQwqMFle3w1TC6NMjqM4mnF6LwoBFijaMr_9Ks8 279
pipeline/clients/base.py sha256=9E7ZsMsVfe3KBs_r4VvujHH5P2ih8-sXmfHgYLi7b-U 1848
pipeline/clients/kafka.py sha256=0Bfa8QDhbuMT8CEX_TuJEyZfhF0N-ycYkhEaNdd2IGE 1438
pipeline/clients/mock.py sha256=6qtqPiXcyHg3PrNofu3hO3hWC_tGD8iGRTHoBfOI9oI 1911
pipeline/clients/mqtt.py sha256=adDNdjuT6ekHxbHVWO1g3BHjrl3KVHKXa0-unIzA-7A 1864
pipeline/producers/__init__.py sha256=GixHIvojS0-Wc_M0Bl-gRLQMNhJrgHnCMFWKPFrkZQo 730
pipeline/producers/base.py sha256=XRrrSsKkW5JWcLBnFzgYMG_4zgLW6DztVFazfPxOx2I 1184
pipeline/producers/kafka.py sha256=5m5lzfKO-E60S-8_n0U_Fh0aHErjyn9tqaStumGi36A 1082
pipeline/producers/mock.py sha256=uFQpb0d4yoXFfqbbw1AEAE8fzyezjNkvpyAO5cPjAdo 514
pipeline/producers/timescale.py sha256=riKpvbTaA_5VeNC01ZH5Ad_1O-8j0JHk87x7amu4kBI 4127
pipeline/tests/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pipeline/tests/clients_mock_tests.py sha256=_lzB-cC7MNBwtn_1nzALXrIFgzPdvt1Hob3CJVMfQsQ 674
pipeline/tests/producers_timescale_tests.py sha256=45HyrGxOhVdM5dNHOWIK-1HVrg0nAdzz0qU_N6CtkLE 2462
trell_data_pipeline-0.4.11.dist-info/METADATA sha256=uJflt4uI9zvXEGN2MeWQAQ8Ch93koIs2g0cgq8aM0A0 889
trell_data_pipeline-0.4.11.dist-info/WHEEL sha256=8zNYZbwQSXoB9IfXOjPfeNwvAsALAjffgk27FqvCWbo 110
trell_data_pipeline-0.4.11.dist-info/top_level.txt sha256=Qdc1eKrvhKK_o9CPbdooOdDt7g3ZSXZDrNXHmUGl94Q 9
trell_data_pipeline-0.4.11.dist-info/zip-safe sha256=AbpHGcgLb-kRsJGnwFEktk7uzpZOCcBY74-YBdrKVGs 1
trell_data_pipeline-0.4.11.dist-info/RECORD

top_level.txt

pipeline

zip-safe