cetl

View on PyPIReverse Dependencies (0)

0.3.0 cetl-0.3.0-py3-none-any.whl

Wheel Details

Project: cetl
Version: 0.3.0
Filename: cetl-0.3.0-py3-none-any.whl
Download: [link]
Size: 59969
MD5: 24053f822b900da81826b02ab77f1437
SHA256: 7674b8ca2604f7f4d58e3486555a8eec0571875f9371743bf23df3ed98df450c
Uploaded: 2023-06-20 10:44:39 +0000

dist-info

METADATA

Metadata-Version: 2.1
Name: cetl
Version: 0.3.0
Summary: A basic data pipeline tools for data engineer to handle the CRM or loyalty data
Author: Clement
Author-Email: <cheukub[at]gmail.com>
Keywords: python,data pipeline,pipeline
Classifier: Development Status :: 1 - Planning
Classifier: Intended Audience :: Developers
Classifier: Programming Language :: Python :: 3
Classifier: Operating System :: POSIX :: Linux
Requires-Dist: flask
Requires-Dist: SQLalchemy
Requires-Dist: pyspark
Requires-Dist: pandas
Description-Content-Type: text/markdown
License-File: LICENSE
[Description omitted; length: 7803 characters]

WHEEL

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

RECORD

Path Digest Size
cetl/__init__.py sha256=f072ZNkltvnoLKb1Q_wilUf0a--t7Wq0hnwKsMDhOUk 554
cetl/dev_tests/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
cetl/dev_tests/sample10_test_parallel_at_beginning.py sha256=qx6avPOsyGYXVbJdRlcRaJXxadUdqumpHXMTcSiQEh4 836
cetl/dev_tests/sample11_adding_kafka_media.py sha256=_8jDhkEh046iQ9NKhmCR4wLtmCFH4F5KelGzeh3hx64 1216
cetl/dev_tests/sample12_test_dummyStartEmpty.py sha256=qTqzKqdDU3YHl-wxgeM3juLhVNiOtJsADk-W95erXlQ 1265
cetl/dev_tests/sample1_test_for_pipeline_v1.py sha256=WMAIWxJ4awg-oSQd0uH6tu7Np5iktvFdrbGkxWEBdL4 935
cetl/dev_tests/sample2_test_for_pipeline_v1.py sha256=q3L5txReu4brZnHfxJRHQoligL4R2YZ96HSrL-YEBf4 1372
cetl/dev_tests/sample3_test_for_pipeline_v2.py sha256=e-S72fbPiabCmlZlUWiymv-p5TDduCWK6B4QaHPXdtw 1373
cetl/dev_tests/sample4_test_for_pipeline_v3.py sha256=M4zg8TY7DP_5xQvIASbEm4w22k7PPObtihQSFOfQPPs 533
cetl/dev_tests/sample5_data_container_type.py sha256=SLU8azzZdagY2HFpuHcvI784l_tPNYP-KfyGsKd5OZo 591
cetl/dev_tests/sample6_build_pipeline.py sha256=Ij7RQiZ37Rmc_oI28EMjyShiP87BblTbjnYUnS_OAbE 542
cetl/dev_tests/sample7_build_pipeline_from_cfg.py sha256=y2ZHqMDS8jSR6GqkWBxqh7wL3pFK7c7iLc5tXX1HaW4 718
cetl/dev_tests/sample8_build_pipeline.py sha256=YxAjnHXe27Jlv2OuKO_2z3oy8-hJZ1NYrC0fSilCHYs 1042
cetl/dev_tests/sample9_build_pipeline_from_cfg2.py sha256=OwjawucsSZkuv7AYop3HaqVgzwr_2C3GfO8gcOEKhd8 911
cetl/functional_modules/__init__.py sha256=NPDZIWADLrP73GCRyHaMmaZkYZJ7x1nu5_4FrAhdrxM 169
cetl/functional_modules/dummy_transformer.py sha256=SBtmB5pP0JagJN4JXBgdUBTjvk8JJFSSRMGLdjdvy9s 571
cetl/functional_modules/multithread_transformers.py sha256=LVcVjvEp7Ga9sJl63QzeBeMpZ-yG_qO90a84vS_oTuE 1342
cetl/functional_modules/parallel_transformer.py sha256=DmUnhb9X7nr761cKRYSDFQDvEoIpDzo2Oy9I6xkHxds 1480
cetl/functional_modules/pass_dataframe.py sha256=_c6RiPprunB-VegWqy7gOCWEcH0Lp0dwlkJf8HG1CHc 737
cetl/json_modules/__init__.py sha256=UzqOvB5Nu5_BDaJvg6uMD8EmLC7E8BjDr6VimdKR1vU 65
cetl/json_modules/drop_columns.py sha256=hMCey8VYb1K6zWI8pJgFxJNV67fxvuptLCJh6GdXta8 668
cetl/json_modules/input.py sha256=NH7mEMviX3K9h0Nz61zz3mxDxxsyhmgZ6GtCix0ZGfU 1079
cetl/pandas_modules/__init__.py sha256=3oMiqOwGZp9CVUZMoYPQ_ab1Ns9r5CevZfd2bxplPgk 974
cetl/pandas_modules/add_new_column.py sha256=0CNYvV3imdyaOqjPmPux4loYkIE-VxdtYecpJCerlfg 20761
cetl/pandas_modules/add_row_number.py sha256=go7Iuidj-qkvkypLA0LUENOY5yhB0gd1lxauBuLWvD0 751
cetl/pandas_modules/dataframe_mgt.py sha256=g9AUd3v20F_E2pEG0FfBpNQg9-hjYCYEPJWzow2ciYw 1817
cetl/pandas_modules/filter.py sha256=OoxHR7G2Py3uXet3phBje9dRrjA01gtkgy405jqq6uE 2717
cetl/pandas_modules/input.py sha256=zKxJi_YM-6R9xHptSGh7v5WqM8CvOlFIQJb-ztzzIqM 914
cetl/pandas_modules/pass_dataframe.py sha256=SpdBXUbRWvSBBt9Ow-NUmQbQz9Ie8vmjrixSKjEKZkU 1187
cetl/pandas_modules/two2one.py sha256=LLfIWk0nA26NLbYVgRyDAsCL0MhtgcPI-FrOGuEZ-jU 3304
cetl/spark_modules/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
cetl/sqlalchemy_modules/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
cetl/utils/__init__.py sha256=OJZVvouWFnh9BYbdKeIDjvj7Ai0Mfb5QSGrMoOcHjRM 71
cetl/utils/airflow_pipeline.py sha256=3wPoEX3ZVa_HGk6rGIhT3SjJRHLlYab7Jq8xrUmXmlo 975
cetl/utils/base.py sha256=8hRT4paAndJDhNj28e0ZLbY9-rS0evGXpw8NDSwoVXI 1012
cetl/utils/block.py sha256=gC4IvvO3XWbBqPBRPVxdfRZf0rQ2SWQzuTkATkGJmSw 1611
cetl/utils/builder.py sha256=SWEUuilLgBwEcYlFT9ND9QPKzChLWDqcsVMiUIItHr8 2742
cetl/utils/dataframe.py sha256=XY2_As8n0-D4Gtxljb-CTmmOKVCQxfIKhTuEF12Tvrk 7727
cetl/utils/dot_node.py sha256=TaCPkyEGt0hy2nzGKEJLocI4CxsaY9NYTUlO3I3YNxs 11585
cetl/utils/encryption.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
cetl/utils/file_mgt.py sha256=uzZr3S0ILxY3DNTRpAyhd7LUeIaoLV1HG3XwafBkJwI 1154
cetl/utils/formating.py sha256=b9oFzCNLprMzJIltlH8JrQ407WhAxPUVFiSpMfyLbkQ 1329
cetl/utils/kafka.py sha256=LOIh3WBLK8AF1vWYeEfLC-bqcQhfKvbg7TDGZuZUxAI 98
cetl/utils/kafka_helper.py sha256=tkl6YeUgYMfJgyfyszWJY3bExYKnGJfDBGCO5xY_bYE 4297
cetl/utils/kafka_media.py sha256=WjZ1pweGTS19QwdA-p_abOUDswFG9yaq9OcNyuXhKlk 8691
cetl/utils/pipeline.py sha256=TRvxzI7sFAeUy9TS_qiPfayYo6jeynwsGaJD9ZMIWBc 32463
cetl/utils/registry.py sha256=C_PxfOXJm4ruikbL-5SSY0RTUlij2Res6L5B91sOB48 1431
cetl/utils/samplings.py sha256=T3AwJrkShfj-kWwgeLgBMOus6TVvg_YIrncbZ3Wg-0w 479
cetl/utils/sftp_file_mgt.py sha256=rnOUaG-OfaA_N7bOeDUKtaFF2zlBtW7UV4jFWfrfG9A 7202
cetl/utils/transform_wrapper.py sha256=T9TQh1TDIEQNZpRcVFMrPpTFPdnsz_2a2YZoRHItphY 8211
sample_user_project/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
sample_user_project/app.py sha256=r_-Q9YcWoE3XB2kO1gjYxWq3-DNb_Hyflz687dYmOHk 3120
sample_user_project/call_api.py sha256=zw06J6ZxS3nlZCAuh_JvBEKB8j2tZ4ScT_WlFvFt41s 2308
sample_user_project/compress_files.py sha256=ImJkScuxWXiJWEYJgZNppbr3G79d9KL0Ct4VyAtJXEk 3438
sample_user_project/test_file_compress.py sha256=_uBD9EhDyUUEgDxEoRVqKW4ijZRqghX9eBZ56FMjNUs 555
sample_user_project/file_modules/__init__.py sha256=-364gAfSszF15LCT48yOWmGISbNjajw063n5bz1HRtU 465
sample_user_project/file_modules/builder.py sha256=DlojE_uASugRF0NBw-YSa72w-ElE5piRG0yd58SXiJQ 220
sample_user_project/file_modules/file_compress.py sha256=QzOyy0jn4SW4GKZbpLYw6Vjbh7QvsQBjYc1jndsdLBM 16094
sample_user_project/sample_modules/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
sample_user_project/sample_modules/add_new_column.py sha256=ip2fm0vPoaO0komez_VGKUHKD-Sl_namgdSU7CVmxdo 749
sample_user_project/sample_modules/data_validation_check.py sha256=LnYwuOS2Rn7r0NygfBuTg6TD_1Ew2JPyyknilpRqQH4 963
tests/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
tests/example1_test_build_pipeline.py sha256=aNAstJpJxh17OqWTGuuGv5-BIycGOJdjVZcETdPtyE0 361
tests/example2_test_build_pipeline.py sha256=4cQXa3CKmSqNQnlY3_1130DlcVt0NxujH8fj-RMq5-8 1091
tests/test_build_digraph.py sha256=HXAJ1G3cf3hdT_Roz-1umGP5mNOmq1vUYWgNRM5tGxs 1107
tests/test_kafka_helper.py sha256=-8Gl1Gl9D4hrN2emkdHUJP2Wu9_9YxDHPcxY13GpTxM 1208
tests/test_kafka_media.py sha256=-BlLpWchzMnBOqkhB3bfd5abYQHVM15JM9hOKqkytyU 2240
tests/test_parallel_transformer.py sha256=eycet8EsdrLHONctzV8in2zk3SMsrdkS9-PdivtwAlc 1282
tests/test_pass_dataframe.py sha256=2CizXB-ngCKXaq6QS-iodGSvk2BNUarRwCAVGYtF_TQ 571
cetl-0.3.0.dist-info/LICENSE sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
cetl-0.3.0.dist-info/METADATA sha256=2DSKM8ylsMN251avQB5teOvdPxt8HZjELntkbTSjrlE 8371
cetl-0.3.0.dist-info/WHEEL sha256=G16H4A3IeoQmnOrYV4ueZGKSjhipXx8zc8nu9FGlvMA 92
cetl-0.3.0.dist-info/top_level.txt sha256=A696iISJPsavn-jY1brDBtxZxd_ePhiB1Th_EIYGmPI 31
cetl-0.3.0.dist-info/RECORD

top_level.txt

cetl
sample_user_project
tests