Wheelodex » Projects » unipipeline

unipipeline

View on PyPI — Reverse Dependencies (5)

1.9.4 unipipeline-1.9.4-py3-none-any.whl

Wheel Details

Project: unipipeline
Version: 1.9.4
Filename: unipipeline-1.9.4-py3-none-any.whl
Download: [link]
Size: 64433
MD5: 035807c0c8e69d6b25cab690610c4134
SHA256: 0542431351212775985e419c49616bf5ca55eea9efa3d3557298d541928d03cd
Uploaded: 2023-09-19 07:50:50 +0000

dist-info

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

METADATA

Metadata-Version: 2.1
Name: unipipeline
Version: 1.9.4
Summary: simple way to build the declarative and distributed data pipelines with python. it supports rabbitmq or kafka as a broker
Author: Aliaksandr Master
Author-Email: alxe.master[at]gmail.com
Home-Page: https://github.com/aliaksandr-master/unipipeline
License: MIT
Classifier: Intended Audience :: Developers
Classifier: License :: OSI Approved :: MIT License
Classifier: Programming Language :: Python
Classifier: Programming Language :: Python :: 3.6
Classifier: Programming Language :: Python :: 3.7
Classifier: Programming Language :: Python :: 3.8
Classifier: Programming Language :: Python :: 3.9
Classifier: Programming Language :: Python :: 3.10
Classifier: Programming Language :: Python :: 3.11
Classifier: Operating System :: OS Independent
Requires-Dist: jinja2 (>=3.0.3)
Requires-Dist: amqp (>=5.1.1)
Requires-Dist: pyyaml (>=6.0)
Requires-Dist: types-pyyaml (>=6.0)
Requires-Dist: pydantic (>=1.8.2)
Requires-Dist: psycopg2-binary (>=2.9.3)
Requires-Dist: pika (>=1.2.0)
Requires-Dist: crontab (>=0.23.0)
Requires-Dist: kafka-python (>=2.0.2)
Description-Content-Type: text/markdown
License-File: LICENSE
[Description omitted; length: 10229 characters]

WHEEL

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

RECORD

Path Digest Size
example/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
example/args.py sha256=DjgHrdxzGAgehxPb8wmtnHTsCrR4HpJu9qz3pnVMsZk 1811
example/example_consumer.py sha256=WGdXHzWpOeosqJ0zSjgMe1mRS3L_T_Ghuj-1vywx_Lk 299
example/example_cron_producer.py sha256=aWW9Y0WNc6hST78FXUiVI0_aM_CCIQgcgaov0_3gk2Q 295
example/example_csi.py sha256=X6kNU88qgl09h0Bsd6iOJxGsHUuORqml-M2Sna6UMfA 281
example/example_producer.py sha256=M9mM7NW09lhT1vzjKXH2aa3NB26PRPYTKu58NRcineY 776
example/brokers/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
example/brokers/kafka_broker.py sha256=BIe871fS_yomnbxzpn3znWO3jv41gQKNn9iyGtIkOiI 294
example/brokers/rmq_broker.py sha256=zzFxfqiHUvexfNu660YjKctMXkcqnrBomlNC-jOs0SA 213
example/brokers/uni_log_broker.py sha256=2xoMPZPFqxFe9Jhcd1mM6Jpt_mC_6g-SOQJHBHBOEow 86
example/messages/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
example/messages/ender_after_answer_message.py sha256=g-aZVxWP3ZTROoS-B2xqBFzSU4AiRfUDzIPpHxVBxBI 115
example/messages/ender_after_cron_answer_message.py sha256=aYV2Jah_MXp_Nex3a5CmR9M0dcCGNuUi7sKu_UzV59w 135
example/messages/ender_after_cron_input_message.py sha256=heRy-tVjRvt5XH59Fy5AkHaJZb5X6gJs_dxcOESDE0c 133
example/messages/ender_after_input_message.py sha256=9yPPFvqBKFbKyZUrXKvCqiNNvqJRoCY_RAfzPL9dfKw 114
example/messages/input_message.py sha256=PloJkt626rpCgW7O3LV4sW31FkY3R1jJps2yN92hFIY 118
example/messages/some_external_message.py sha256=og_fcr2L5Eudww6sO01CQFzhTrb9bmWQJpoAcHiMgxk 111
example/waitings/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
example/waitings/common_db_wating.py sha256=tgMizba_st8jywThhj9fz6eNxGEy2hpYtSa0YEBi5rM 142
example/workers/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
example/workers/auto_retry_worker.py sha256=zfXmPsV5p5MVJIk5GtMSNNcWHXo0t64a0GQ1ZMppmLg 407
example/workers/ender_after_cron_worker.py sha256=fcfSoKBHuh1zHF88fzkBBPFcfGH3jmkA5MjUxEbY8ew 682
example/workers/ender_after_input_worker.py sha256=7sIBtrQqJ3yfXf0MUATeAW2Kdjtr7RzEn6EoAjXMfVc 840
example/workers/input_worker.py sha256=yjDc3HRVTbI37yZF3xu6HN__qkJNIKW21IY-3c5pjpw 1544
example/workers/my_super_cron_worker.py sha256=RcXqRDvDqyornds9VvLmGvIjR8u383V-Gqz8qV1E_WM 1028
unipipeline/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
unipipeline/args.py sha256=UlAt75mqqswc3AcbRUaGakprVBvyAR4dDoUzU32PUH4 5142
unipipeline/errors.py sha256=rhAgANVn9IIG3vFOR5696VZY02pVb5YVwQ9ajGEeMc8 896
unipipeline/main.py sha256=HmZAZKPwv-LaXrzwv8zOqlsmZKqQ6EiVEUuNBE8GA4U 132
unipipeline/py.typed sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
unipipeline/run.py sha256=fs7W5O6czufGGsCNlswbaMveCKuusw32Zyl6_Jc64jg 1515
unipipeline/answer/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
unipipeline/answer/uni_answer_message.py sha256=Tu12AyIGapcwzMqXkZHQY8CBAXQJGqSPqzcp5M_RJ3Q 1503
unipipeline/answer/uni_answer_params.py sha256=HkZ0_SqudCK21n_76-iQBtcNTYRGYcSJ1kvVptunAEA 210
unipipeline/brokers/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
unipipeline/brokers/uni_amqp_pika_broker.py sha256=0oWWMCwMMV10iYF5tj19gLwt6Q2en19INzamSkau64c 16198
unipipeline/brokers/uni_amqp_py_broker.py sha256=ziGYViotClfAuXoiLnXG51eNoGUII9xJ91SNHOwqw7A 27163
unipipeline/brokers/uni_broker.py sha256=mPxwFpK1LnmvLekoEpihxR2wFF-kTScI0TO1C8O3udE 4031
unipipeline/brokers/uni_broker_consumer.py sha256=xeOtEcwYtQT3y6jMAhCrZHMKTRgPQjKTy1ZR7XkzZZI 306
unipipeline/brokers/uni_kafka_broker.py sha256=70BHJMBBit23a0Ki6vqpByRTQ-9X1wlkIR1aqoobOpQ 6894
unipipeline/brokers/uni_log_broker.py sha256=fYN685_p9oz-gHMbBBlJbkemQnMAZaYXf9r0cqTgRfE 1915
unipipeline/brokers/uni_memory_broker.py sha256=1Eq-4OzTcKEvPu4dVAspRMFDGOKUMyqX2bsGTOBV7UE 7198
unipipeline/config/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
unipipeline/config/uni_config.py sha256=x6DgVMSX8xrxTK_NqTHy4LDDwm548vwk3Y2I9edz5Fg 21472
unipipeline/definitions/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
unipipeline/definitions/uni_broker_definition.py sha256=L-QF0CvI7Xq3XddlkXCfMlvzrB_BFYleXQcwI9CTuug 511
unipipeline/definitions/uni_codec_definition.py sha256=SQMxSWSBvBZboUsoQ5JztwYqK1yvLODbGxDQioN-aTM 276
unipipeline/definitions/uni_cron_task_definition.py sha256=PNFbjApDDeGy9tYltQ-zD3QXx1aVSO2VRIDKfCd4QVU 1243
unipipeline/definitions/uni_definition.py sha256=JxvLfz1Dlww8fLowHR0FOlyZFINxSUpCDqzZvhSusbs 697
unipipeline/definitions/uni_dynamic_definition.py sha256=m7dp2iKweu6kSqPWrNzjPp7tixF033KndxVuzp0sIh4 179
unipipeline/definitions/uni_external_definition.py sha256=ucfYy0GmcmvoSQ0Z6k1V3ih_sLL80y6oRviAdcE_KkY 161
unipipeline/definitions/uni_message_definition.py sha256=GE_LiS-Sx6C9u599s617PeyySamB5g4ZVQJIXmAQ4HA 232
unipipeline/definitions/uni_module_definition.py sha256=P31yvgJOj_js-kVgSdvOWfsaB8jjWE2QVYOwxPHNr9w 5911
unipipeline/definitions/uni_service_definition.py sha256=bfiDGnw0CWpb4vx4UfUy2OFlI_3EdO5FYEcbDc6tkos 158
unipipeline/definitions/uni_waiting_definition.py sha256=6y0hRHiSEm5sCV2AKc9YaFfLoZBp3mJKingYoYdAwHo 1128
unipipeline/definitions/uni_worker_definition.py sha256=CJ_8AtkmuNxyY7LHAq3aYacNtm4pg-ZT_6hhgYiusek 1127
unipipeline/message/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
unipipeline/message/uni_cron_message.py sha256=5TMdtJlGkDt1EXwHemXRSja7OMB3QHcBol44-qhu9Rc 110
unipipeline/message/uni_message.py sha256=QHGunUTRFJY9kbQs9H5Y4_D-IG7S7BRQgFX7il4vAGM 116
unipipeline/message_meta/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
unipipeline/message_meta/uni_message_meta.py sha256=RreXu1huK-8bA7Xfvg7ABULbzJEwJWuUP0bTSrCVdlU 2794
unipipeline/message_meta/uni_message_meta_err.py sha256=sbeC1g7slwghS6RMkpKk6pG4l8mtL2LLTbhFxmn6LSM 340
unipipeline/message_meta/uni_message_meta_error_topic.py sha256=y3dRhpSctJaVVhxqKP7MOgCH9gcxrWNjaq56eAq227Y 328
unipipeline/modules/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
unipipeline/modules/test_uni_util.py sha256=b7K539tVnRSEYTAvXclp6TRMCgaZ7CTUu-khZ8hAQnw 416
unipipeline/modules/uni.py sha256=0aAXUTFGd4G8K3ildlTvVMhnJk0nhZGbRlExSd8sNcQ 5102
unipipeline/modules/uni_cron_job.py sha256=H7gCKaBSq0b7iWdexHpQRoTo_zPgYbKm82IZKwYxrT0 2160
unipipeline/modules/uni_mediator.py sha256=aEd-Zgru6eZ2DyzhjLfE8h1fhGAMgnYJmEfr4p85Jxo 21140
unipipeline/utils/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
unipipeline/utils/complex_serializer.py sha256=ABIUB4oEIrquyvTfPBU3xNHPeKrWwKIZcoddhF1wl_s 693
unipipeline/utils/filter_camel.py sha256=KA2XJAdqy3Qn8G83fr0cTzJaqJVo_Ux30aws70ClLeE 111
unipipeline/utils/uni_echo.py sha256=RAShxtFZiZgOVdtjm72EaYwpEiOTokXJoi5IZ-JLqHk 2902
unipipeline/utils/uni_util.py sha256=In8ZlNvKhviXL7HsGO0eHhNHc6YgoCu8r3mdOcj3EKY 418
unipipeline/utils/uni_util_color.py sha256=phZIRXpcmaLLQ7sFNrR1fLBaA0AJHZujPkJtoskHfB0 737
unipipeline/utils/uni_util_template.py sha256=tAaLW5wGKKld-Dsrm59l3H-HNT5iaRCwOLK1S19OwCU 798
unipipeline/waiting/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
unipipeline/waiting/uni_postgres_waiting.py sha256=exJHTrXNzt8V9KoNqs2hc2vt-nEaZ8Zp3AVofSsr9dQ 780
unipipeline/waiting/uni_wating.py sha256=Qrh0DQ5QpwUetqP05Pqi4kxDS3rVfJrsnAMD_m7mUkM 133
unipipeline/worker/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
unipipeline/worker/uni_msg_params.py sha256=EMOh0nUt2UlYbWlEU5oN61WHIaJCHOuxMgf5YxvXtPA 899
unipipeline/worker/uni_worker.py sha256=nUO3_QiOJGb083lPxvIVe_oldbR56lAy64CGHaa2qW4 910
unipipeline/worker/uni_worker_consumer.py sha256=Otrx2zQBT_kB731mJ_HiX3amoZ6S47chcWlhQOec0Jk 5375
unipipeline/worker/uni_worker_consumer_manager.py sha256=0BKLVO-YaEGsnjJFJ1WbTBbjVetryzV4MucRnUROhyk 1786
unipipeline/worker/uni_worker_consumer_message.py sha256=SK9QdtMzddOZxHawxhfykblx-SNVH93NpRtJsGgwGYE 1618
unipipeline-1.9.4.dist-info/LICENSE sha256=lyKWNwDMzYHbssAKrIptpzNRdyqlFzknUgcgLa7LGyA 1063
unipipeline-1.9.4.dist-info/METADATA sha256=IHkYCtMJambA8yWyiMunRg1Q-SpavV5tWlXTCyLols4 11405
unipipeline-1.9.4.dist-info/WHEEL sha256=G16H4A3IeoQmnOrYV4ueZGKSjhipXx8zc8nu9FGlvMA 92
unipipeline-1.9.4.dist-info/entry_points.txt sha256=kIjzt93_Y8TKhVVZgy4Y6cgiV_Fzbpi8dcDuIdxJCw0 54
unipipeline-1.9.4.dist-info/top_level.txt sha256=c20-gsXu--deGaO-zT67yhB3TQ2m-C1UEyGyH3jBzM4 20
unipipeline-1.9.4.dist-info/RECORD — —

top_level.txt

example
unipipeline

entry_points.txt

[console_scripts]
unipipeline = unipipeline.main:main