Wheelodex » Projects » tanbih-pipeline

tanbih-pipeline

View on PyPI — Reverse Dependencies (2)

0.12.13 tanbih_pipeline-0.12.13-py3-none-any.whl

Wheel Details

Project: tanbih-pipeline
Version: 0.12.13
Filename: tanbih_pipeline-0.12.13-py3-none-any.whl
Download: [link]
Size: 212188
MD5: be5226cc9e45f45caf3dc951855af5cd
SHA256: 684bfcef7533e9cf376cc06b8363d5a5173644b46d492019b5fd54093189a0e4
Uploaded: 2023-10-08 09:22:44 +0000

dist-info

METADATA · WHEEL · RECORD · top_level.txt · entry_points.txt

METADATA

Metadata-Version: 2.1
Name: tanbih-pipeline
Version: 0.12.13
Summary: a pipeline framework for streaming processing
Author: yifan
Author-Email: yzhang[at]hbku.edu.qa
Home-Page: https://github.com/yifan/pipeline
License: MIT
Classifier: License :: OSI Approved :: MIT License
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.8
Requires-Dist: prometheus-client (==0.7.*)
Requires-Dist: zstandard (==0.15.*)
Requires-Dist: pydantic (<2.0,>=1.8)
Requires-Dist: python-dotenv (==0.19.*)
Requires-Dist: azure-cosmosdb-table; extra == "azure"
Requires-Dist: elasticsearch (==7.*); extra == "elastic"
Requires-Dist: redis; extra == "full"
Requires-Dist: confluent-kafka (==1.*); extra == "full"
Requires-Dist: pulsar-client (==2.*); extra == "full"
Requires-Dist: azure-cosmosdb-table; extra == "full"
Requires-Dist: pika; extra == "full"
Requires-Dist: pymongo (==3.*); extra == "full"
Requires-Dist: elasticsearch (==7.*); extra == "full"
Requires-Dist: rq (==1.10.*); extra == "full"
Requires-Dist: confluent-kafka (==1.*); extra == "kafka"
Requires-Dist: pymongo; extra == "mongodb"
Requires-Dist: mysql-connector-python; extra == "mysql"
Requires-Dist: pulsar-client (==2.*); extra == "pulsar"
Requires-Dist: pika; extra == "rabbitmq"
Requires-Dist: redis; extra == "redis"
Requires-Dist: rq (==1.10.*); extra == "rq"
Provides-Extra: azure
Provides-Extra: elastic
Provides-Extra: full
Provides-Extra: kafka
Provides-Extra: mongodb
Provides-Extra: mysql
Provides-Extra: pulsar
Provides-Extra: rabbitmq
Provides-Extra: redis
Provides-Extra: rq
Description-Content-Type: text/x-rst
[Description omitted; length: 8444 characters]

WHEEL

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

RECORD

Path Digest Size
pipeline/__init__.py sha256=ePglbfevXbWcxKGumwYPHwxaAMZi_f-W-6KUwx-hwtU 906
pipeline/__main__.py sha256=b0wSgmdzf_udX9W96mizxKpC9Nd7rRUFH8hNdqeCbNY 1370
pipeline/exception.py sha256=lYU3sNT3gR0dnm9aLSWCL6QPvh0b-HMDV7Lf87Myr8g 696
pipeline/helpers.py sha256=R2XG3QaHIEJuoahSxTRcOTkXc54GftVwEiJM9oyz8GM 7363
pipeline/importor.py sha256=U2y752NYUsoSefYLIX1XcMtedgGIldvz7hS9ZKtaigk 558
pipeline/manager.py sha256=WbhKO2IRESEzlLTDIferGg0LSs7Hzq4FSNEQFvPjTKM 4765
pipeline/message.py sha256=kYHU-AOQIjs1_ImwBH-M09y_2S81-GIXRN5TWHDy7aU 3665
pipeline/monitor.py sha256=81TOqqRfAHMXWMo1jD2vfredI7EKidAp4BSx0ySxWh4 5201
pipeline/tap.py sha256=cM2K-rCfqIyJVijUnxqCOsuSlPESwj8otk_wleyKXAo 20147
pipeline/version.py sha256=UMBRG2LGb4az7r6fkF3jd0XFJ6qMccEFgve0PnAGS1c 20
pipeline/worker.py sha256=SYvS96TyylUOvd_T2VJiwCrfzFlOpORH4ZfoUU_bHhU 19498
pipeline/__pycache__/__init__.cpython-311.pyc sha256=IrCocuzyflQ1pTvaZA1rcPuGFocMMVjTxbb-_D1uBdM 1182
pipeline/__pycache__/__init__.cpython-38-pytest-7.2.0.pyc sha256=CrCMcEnuTh56R2ETcC4KWmc2SGZ-XPbS9GB_t9nMzvM 1101
pipeline/__pycache__/__init__.cpython-38-pytest-7.4.0.pyc sha256=CrCMcEnuTh56R2ETcC4KWmc2SGZ-XPbS9GB_t9nMzvM 1101
pipeline/__pycache__/__init__.cpython-38.pyc sha256=0_74gPKO6_rVHH6KkVhdA8NaL1BMnaf6Se6v2ZpV-sM 983
pipeline/__pycache__/__main__.cpython-38-pytest-7.2.0.pyc sha256=xEZ78Itp2HrVnTeOGcQNWJ4ozD3IutIaH8bz2VRCHig 2216
pipeline/__pycache__/__main__.cpython-38-pytest-7.4.0.pyc sha256=4J_-zshS7WPeChTHmDiJvfAz2CclfKV6R1Wyp9Cipe8 2216
pipeline/__pycache__/exception.cpython-311.pyc sha256=zCuzkiqyaxrSM6OQWZrezB-6NTsftKo4IWbZv0NZHaM 2131
pipeline/__pycache__/exception.cpython-38-pytest-7.2.0.pyc sha256=5beUKENAbfiKss83RCh84lnybNVgPv9eDGPQkj5O1B4 1452
pipeline/__pycache__/exception.cpython-38-pytest-7.4.0.pyc sha256=5beUKENAbfiKss83RCh84lnybNVgPv9eDGPQkj5O1B4 1452
pipeline/__pycache__/exception.cpython-38.pyc sha256=kj-A_MQjJU7tdvqcFGtFHQKopsXNzp4rW5aA93NjHUs 1339
pipeline/__pycache__/helpers.cpython-311.pyc sha256=fwp_INyctittp7FuVMnqC45H9rGootdeLUWEmhoaRQE 11523
pipeline/__pycache__/helpers.cpython-38-pytest-7.2.0.pyc sha256=SY_zn-qhNhlBsjgFvKcLe7tFWZ3TJR8fyQJRF6gQqqU 7080
pipeline/__pycache__/helpers.cpython-38-pytest-7.4.0.pyc sha256=SY_zn-qhNhlBsjgFvKcLe7tFWZ3TJR8fyQJRF6gQqqU 7080
pipeline/__pycache__/helpers.cpython-38.pyc sha256=LXkspgNKSS7hNnPuKZaH8ESIADEzKWaDlTPYoqw_Z9Q 6967
pipeline/__pycache__/importor.cpython-311.pyc sha256=DRpxR6V9QZzY-lQaPezLgT5LFLDnKrGYsFTv_N6_rSE 1177
pipeline/__pycache__/importor.cpython-38-pytest-7.2.0.pyc sha256=VkGS9zJ25XxmM8MeZQH7vIirIIFRijYeNDWJ6YhYFqs 830
pipeline/__pycache__/importor.cpython-38-pytest-7.4.0.pyc sha256=VkGS9zJ25XxmM8MeZQH7vIirIIFRijYeNDWJ6YhYFqs 830
pipeline/__pycache__/importor.cpython-38.pyc sha256=P8g7On-f9FsMl5N0sVXTikavIy2bAKOQocf0PUNO6DQ 717
pipeline/__pycache__/manager.cpython-311.pyc sha256=1hj6869GcEgkdQ506jteutstDAHAPftxtFN4SreSejw 6579
pipeline/__pycache__/manager.cpython-38-pytest-7.2.0.pyc sha256=Q7iZvrgNTczzsmFRilP8XiV_7-EIpBabBFJe4mdtbE8 4526
pipeline/__pycache__/manager.cpython-38-pytest-7.4.0.pyc sha256=Q7iZvrgNTczzsmFRilP8XiV_7-EIpBabBFJe4mdtbE8 4526
pipeline/__pycache__/manager.cpython-38.pyc sha256=LN__CsNeGjrEZruIqVYVfMpjknrIhlYBOvappTMDC1o 4413
pipeline/__pycache__/message.cpython-311.pyc sha256=EygSyBTKZ0396hDER5CKs4PvIjIA5vGcvi3RW15lIEs 7612
pipeline/__pycache__/message.cpython-38-pytest-7.2.0.pyc sha256=owtTPK6_uUWeTiRp3QnMprhBtvy41N48lq88EHGVY7c 5097
pipeline/__pycache__/message.cpython-38-pytest-7.4.0.pyc sha256=owtTPK6_uUWeTiRp3QnMprhBtvy41N48lq88EHGVY7c 5097
pipeline/__pycache__/message.cpython-38.pyc sha256=704qxWOMtjauMbHOBZP50u4uN0HqZARsbYtTfCHRn6M 4984
pipeline/__pycache__/monitor.cpython-311.pyc sha256=iGFIzO5iLDIdYKQcjHJh1UzUmLZrVECXGo3OoceSOuM 9081
pipeline/__pycache__/monitor.cpython-38-pytest-7.2.0.pyc sha256=QV3vgTkxBXyqjJ-rl-x7EEUENWY5Q2A0qSzLmR08QDQ 5401
pipeline/__pycache__/monitor.cpython-38-pytest-7.4.0.pyc sha256=QV3vgTkxBXyqjJ-rl-x7EEUENWY5Q2A0qSzLmR08QDQ 5401
pipeline/__pycache__/monitor.cpython-38.pyc sha256=VzfCGpXfN8LYes1Q2S8HTNRPHfzcfHl05QQmToqh1iw 5288
pipeline/__pycache__/tap.cpython-311.pyc sha256=5xZ7S_cQkVBJYuP2L3QGuO_GRgmF8b9zGqwodZ8dEjk 32868
pipeline/__pycache__/tap.cpython-38-pytest-7.2.0.pyc sha256=3n8G2_tIM_vhKI5y5YTiRy4SrRWllPWOHz7NFTtpXOc 21240
pipeline/__pycache__/tap.cpython-38-pytest-7.4.0.pyc sha256=3n8G2_tIM_vhKI5y5YTiRy4SrRWllPWOHz7NFTtpXOc 21240
pipeline/__pycache__/tap.cpython-38.pyc sha256=8oF0hes_jp0EzUNQNwrLcgT0Fp2YQGMqYynurDDQF8w 21127
pipeline/__pycache__/version.cpython-311.pyc sha256=xEzeOVXsZi9yWVGnXrIe1ZtNXuSXBQYZ89szmFdQF_M 184
pipeline/__pycache__/version.cpython-38-pytest-7.2.0.pyc sha256=7yHL97QLYSN5kpz0LlxZTp27mMU-vYH0sHgL8HUvapU 284
pipeline/__pycache__/version.cpython-38-pytest-7.4.0.pyc sha256=OdG8yzic9xiTFyHZVY0Ww02n-I7KuqYQ-0NHKHIAqmA 285
pipeline/__pycache__/version.cpython-38.pyc sha256=nATrn6AsCn9gKjXi7c2txsptcr1X2WJyf5Aj2C5-iWQ 167
pipeline/__pycache__/worker.cpython-311.pyc sha256=4K3bWijsOp41tgho6MaeHudRXiVt3PsVC7dgbcsdntY 33203
pipeline/__pycache__/worker.cpython-38-pytest-7.2.0.pyc sha256=ZzAT7SHALw4xl7P5hE5XL1CYi4Xn44KVsLPETy5wFA8 16906
pipeline/__pycache__/worker.cpython-38-pytest-7.4.0.pyc sha256=bKwW6DtA5bypuvW7DtgvRY9p4_1aeN2CeOX5d64chcY 16906
pipeline/__pycache__/worker.cpython-38.pyc sha256=aT0-OJj5tR7iloImliDHDO-t5ZJNfFMrifEJmNazYmY 16793
pipeline/backends/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
pipeline/backends/elasticsearch.py sha256=-CIfiMVun14bJNgFLNnm42iBtbNO11eXeMPPvB2nKCo 3333
pipeline/backends/kafka.py sha256=M_2-MBawtDNwvhrHCEA3nfo7nQgiTvach5uavnvJF8M 6036
pipeline/backends/mongodb.py sha256=_QPZ30VRUtVUTwlqUooeuX2tI_YuoNmQS2GGzDx17NI 3671
pipeline/backends/pulsar.py sha256=0ExJqhUGEP3mMdUGtQXhw8yfQOO8QF30C3L8JetjL2w 4446
pipeline/backends/rabbitmq.py sha256=Tla75WaW1_iyQBEFEOLYL3s9cT3_oN1GC9JIeDJvJSo 6094
pipeline/backends/redis.py sha256=dJMATrOOcDiRfhrBcbNaRZiQxDCl53LMAPqiMOiEfEs 9592
pipeline/backends/rq.py sha256=sSMNSXp5xGtZWYsVS2X9PIJwPcW2vxL7jUGEE4LfLA0 5247
pipeline/backends/__pycache__/__init__.cpython-38-pytest-7.2.0.pyc sha256=RXB29ItjPDvomZuxGfkSQqeJOI2PhveT3sZ6y7kdXp4 158
pipeline/backends/__pycache__/__init__.cpython-38-pytest-7.4.0.pyc sha256=RXB29ItjPDvomZuxGfkSQqeJOI2PhveT3sZ6y7kdXp4 158
pipeline/backends/__pycache__/elasticsearch.cpython-38-pytest-7.2.0.pyc sha256=rHQFKyGKI_UfTuVQRPKp0TGsno2xrrUpNAyYLTlh9O0 4681
pipeline/backends/__pycache__/elasticsearch.cpython-38-pytest-7.4.0.pyc sha256=rHQFKyGKI_UfTuVQRPKp0TGsno2xrrUpNAyYLTlh9O0 4681
pipeline/backends/__pycache__/kafka.cpython-38-pytest-7.2.0.pyc sha256=hxf6VhNxIoAfGtFdKtcYT_1gZC_S7kDHOWqsADvuCoE 6247
pipeline/backends/__pycache__/kafka.cpython-38-pytest-7.4.0.pyc sha256=hxf6VhNxIoAfGtFdKtcYT_1gZC_S7kDHOWqsADvuCoE 6247
pipeline/backends/__pycache__/mongodb.cpython-38-pytest-7.2.0.pyc sha256=qeNqi4Bs1IVk7qH8nRQmbqomTl_aRtiO0S5xqqrPpfI 5214
pipeline/backends/__pycache__/mongodb.cpython-38-pytest-7.4.0.pyc sha256=LQbd8LrcmGwSSUK44Z2iC61sYUqnz9jOCDxeUg-hHWI 5214
pipeline/backends/__pycache__/pulsar.cpython-38-pytest-7.2.0.pyc sha256=DOKDUoNT7etlG90xPniy5TqUd_sLmFlFqx38ha3388w 5478
pipeline/backends/__pycache__/pulsar.cpython-38-pytest-7.4.0.pyc sha256=gEFTMsWJ1UQuSeqQf4IuuouqWxyycUs9yNXGodYWZoI 5478
pipeline/backends/__pycache__/rabbitmq.cpython-38-pytest-7.2.0.pyc sha256=1S5po5ZO7eN65l4urqFJcYYAcrFEibeYLrupkeXYdrg 6549
pipeline/backends/__pycache__/rabbitmq.cpython-38-pytest-7.4.0.pyc sha256=LCOFIO6uwj2RinnxLpojwSY_qh9-hL6u7U9Pi1Ohapk 6549
pipeline/backends/__pycache__/redis.cpython-38-pytest-7.2.0.pyc sha256=F-_fP7B-HuWHC8--cJYS6D0TIShBMNhupNp6DRS4NGA 10270
pipeline/backends/__pycache__/redis.cpython-38-pytest-7.4.0.pyc sha256=4WsdHXdaiBKrlZ2K9fnjvrkJVlwHiPuBGVRoTFJwFno 10270
pipeline/backends/__pycache__/rq.cpython-38-pytest-7.2.0.pyc sha256=6xsJQooyQbE0WWOgpUHYDDDVnjKlI1brm-JZ-spk57s 5881
pipeline/backends/__pycache__/rq.cpython-38-pytest-7.4.0.pyc sha256=6xsJQooyQbE0WWOgpUHYDDDVnjKlI1brm-JZ-spk57s 5881
tanbih_pipeline-0.12.13.dist-info/AUTHORS.rst sha256=39mx5Kw1hgErd0M6NELYxo1odqbVt4eBY88HydcIKnQ 59
tanbih_pipeline-0.12.13.dist-info/LICENSE sha256=spnIOdliREt_mqtk5S9vobU-wqNdRVQjn3lUSJi_e8E 1100
tanbih_pipeline-0.12.13.dist-info/METADATA sha256=eD0MA18vCOQx0DQuFLZFg7MgqHBnqmlWBPrb4lrNfoI 10106
tanbih_pipeline-0.12.13.dist-info/WHEEL sha256=2wepM1nk4DS4eFpYrW1TTqPcoGNfHhhO_i5m4cOimbo 92
tanbih_pipeline-0.12.13.dist-info/entry_points.txt sha256=7i1D6Vc7zg8M--vGYbGmb-0y2aArBriOVxFyBrPAG94 58
tanbih_pipeline-0.12.13.dist-info/top_level.txt sha256=Qdc1eKrvhKK_o9CPbdooOdDt7g3ZSXZDrNXHmUGl94Q 9
tanbih_pipeline-0.12.13.dist-info/RECORD — —

top_level.txt

pipeline

entry_points.txt

[console_scripts]
pipeline-copy = pipeline.__main__:copy