ez-etl

View on PyPIReverse Dependencies (0)

1.1.2 ez_etl-1.1.2-py3-none-any.whl

Wheel Details

Project: ez-etl
Version: 1.1.2
Filename: ez_etl-1.1.2-py3-none-any.whl
Download: [link]
Size: 93415
MD5: 9052a8fa23651e324847b96959c48358
SHA256: da4bb06a86c0ce8131de7bdffe3cc20ede19476abc31bf7b2fbbdd72f59553ad
Uploaded: 2024-03-01 06:52:59 +0000

dist-info

METADATA

Metadata-Version: 2.1
Name: ez-etl
Version: 1.1.2
Summary: ez-etl is an open-source Extract, Transform, load (ETL) library written in Python. Just configure a dict to read data from various data sources. Use code or built-in conversion algorithms to transform the data into the target data format, and write it to the target data source.
Author: Xu Wei
Author-Email: 1013104194[at]qq.com
License: Apache License 2.0
Keywords: etl,extract,transform,load,excel,csv,mysql,kafka,elasticsearch,neo4j,influxdb,mongodb,clickhouse
Requires-Dist: requests (>=2.25.1)
Requires-Dist: sshtunnel
Requires-Dist: python-dateutil
Requires-Dist: pandas (>=1.0.0)
Requires-Dist: openpyxl
Requires-Dist: xlrd
Requires-Dist: minio (==7.1.1)
Requires-Dist: sqlalchemy (>=1.2.0)
Requires-Dist: pymysql
Requires-Dist: elasticsearch (>=7.17.2)
Requires-Dist: redis (==4.0.2)
Requires-Dist: kafka-python (==2.0.2)
Requires-Dist: mysql-replication (==0.27)
Requires-Dist: xorbits (==0.3.2); extra == "all"
Requires-Dist: pyarrow (>=5.0.0); extra == "all"
Requires-Dist: akshare; extra == "all"
Requires-Dist: ccxt; extra == "all"
Requires-Dist: psycopg2-binary; extra == "all"
Requires-Dist: pymssql; extra == "all"
Requires-Dist: cx-oracle; extra == "all"
Requires-Dist: clickhouse-sqlalchemy; extra == "all"
Requires-Dist: thrift; extra == "all"
Requires-Dist: thrift-sasl; extra == "all"
Requires-Dist: pyhive; extra == "all"
Requires-Dist: py2neo; extra == "all"
Requires-Dist: prometheus-api-client; extra == "all"
Requires-Dist: mongoengine; extra == "all"
Requires-Dist: influxdb (==5.3.1); extra == "all"
Requires-Dist: xorbits (==0.3.2); extra == "xorbits"
Requires-Dist: pyarrow (>=5.0.0); extra == "xorbits"
Provides-Extra: all
Provides-Extra: xorbits
License-File: LICENSE
[No description]

WHEEL

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

RECORD

Path Digest Size
ezetl/__init__.py sha256=C66HyjsAjTviI8G4uR5vH67I0IF9tCAvENC2qp25C8w 5266
ezetl/etl_task.py sha256=ATxtZ5Oc_w1QUT9Rj8a2E3JDM7oi3MK41guKZcXse0E 8478
ezetl/data_models/__init__.py sha256=bjsAsjMEBe0P9REoWClMJY_1gBEyyfpbQ0oj4o5hYlg 2122
ezetl/data_models/akshare_models.py sha256=weQ-25Bm8N9lHcHlETdjgq2cVvtw37UmpIWDtoeYzvU 5914
ezetl/data_models/base_db_sql.py sha256=Odkb3etei99Z0SHcZJtEavu9G6aaa5Lcyh_U4oDigso 4573
ezetl/data_models/base_db_table.py sha256=BuHKfdkdqMgbZ6Yv354NGDlP1e12q9J3JJNK4STQ1mk 14383
ezetl/data_models/ccxt_models.py sha256=qrjfd7pShHQqEZzBbD8378rC4uNJozdQJFHo2O6gABo 7754
ezetl/data_models/clickhouse_table.py sha256=EHnxlJf0VTi5tn2g9989p5MbQoUE-MqrIoh5PRC-ce8 2490
ezetl/data_models/elasticsearch_index.py sha256=JwOQeD0LUlz9W34oFxOCo3vKAoeUaX82u1pqiYQ8l_Q 12124
ezetl/data_models/file_models.py sha256=RCYGz6j3NMRtvah8kf7hlSZERPrJBkw_p0vPWT7w2fs 9971
ezetl/data_models/hdfs_models.py sha256=SJQxdevqoO40f7oymuCKAoetVZ_f7YeQS9mEk7hOM8c 426
ezetl/data_models/hive_models.py sha256=eKhJgz8LeSKmQthtbR5BnMS0jZihQaUcL2Fblhtx4iA 1791
ezetl/data_models/http_models.py sha256=3goQIfva3sLZl12U-VoxXQx6PbFuZ2bVBNMd1LsjIsQ 4252
ezetl/data_models/ixdb_models.py sha256=2JFbjSuUM1pGBdxStSpzVGfNs-4Jjo4PnuBNcMjAZ8s 12775
ezetl/data_models/kafka_topic.py sha256=70kBOwS8tAAvAwunbancA7XfExUB-sueVLeYMp3DbHU 6096
ezetl/data_models/minio_models.py sha256=Beix_sG1VaDxJMtf1SmGOEC4B6X1EORwaoKgCHOu_aE 9809
ezetl/data_models/mongo_models.py sha256=7eBuPt2OUfVh4fi4f9joTSsauCyp0rq5yxYp6BC1fzA 9529
ezetl/data_models/mysql_binlog.py sha256=BAUH_6f3swItN6aYXd6FCVHL9K9WvcIz9SUzq5uVps8 6441
ezetl/data_models/mysql_table.py sha256=Fq_ervfCWWNx2nTms6QWjB07ms6wK7D7dVEhhwUHq4U 550
ezetl/data_models/neo4j_models.py sha256=C9MKbBpD4c8Th88Jw6kK6vNgIK9PPJyehy2Dxxcu_qQ 11813
ezetl/data_models/oracle_models.py sha256=_h1_U6QKN6fnJuMb516K8_VCeAISO8VdDdCk1rv175M 2170
ezetl/data_models/pgsql_models.py sha256=KXQS1YbykzZDuTCub4k7PFpdGCBowhJdSZUwedDmV8Y 827
ezetl/data_models/prometheus_models.py sha256=nfEJc5bJBKBjpeQwypZKdq8OEiQ5h-fasNultPcGk5w 8361
ezetl/data_models/redis_models.py sha256=ujwpCULT0i69SvFduNlwjJnDUEHaPogwWS5sM1aH7UY 10534
ezetl/data_models/sqlserver_models.py sha256=QCLe1T_-vx2bUAgDZ4Fib6qJv9p6dxvoDpFj3aXHg04 4130
ezetl/examples/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
ezetl/examples/etl_demos/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
ezetl/examples/etl_demos/binlog2kafka.py sha256=LcCDJmn-bSlOGu0xCFkYaRUIhsqji7PsSNDeJ3Mll1M 1739
ezetl/examples/etl_demos/csv2csv.py sha256=Aux43H0OP750XVkiVRd7oFPSl1zo-DC0nfrutrj7n_c 2321
ezetl/examples/etl_demos/csv2mysql.py sha256=GLg3LmmGBdy5UOlk0Xk9fsUAvEQWGtGB0rYO_6u3LiE 4308
ezetl/examples/etl_demos/kafka2es.py sha256=jy-VXXfPze1LZFw9DeYnX6diCrp2PlnTrwycr_9ZsyM 2474
ezetl/examples/etl_demos/kafka2ixdb.py sha256=qQ6JwtiEO7fKZvo4XlmPXV-NiZQqkTDLhMFIuH6EVQs 2242
ezetl/examples/etl_demos/mysql2es.py sha256=ACqzdRoNQxp2r-NhbQtYhoxyz4iLyLTHRtBEjGpjrR0 2673
ezetl/examples/etl_demos/mysql2kafka.py sha256=1OPMY-fEW_dc85wurnmZNtMLBbPWj_KiS2fKYBXT6Tg 1750
ezetl/examples/etl_demos/mysql2mongodb.py sha256=b1qfCrVB5JAGIwgvGFcOpSPMl32u7QqEQ8HBhwozwEM 1982
ezetl/examples/etl_demos/mysql2n4j.py sha256=g05aCUy0-7hVLfu7gy2tED-PVxi39FI76Z2eMucmaNg 1752
ezetl/examples/etl_task/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
ezetl/examples/etl_task/batch_task_demo.py sha256=gIWMw9kpjTcrqXwpiEjr8F8OjaFalOshy70yCOROvUo 2297
ezetl/examples/etl_task/etl_process_task_demo.py sha256=lwrSQnR35ae1oVJjZYlqJL6-YQHn6tBuYFtoWoUlvuw 2539
ezetl/examples/etl_task/stream_task_demo.py sha256=bCdMKZ8zvHk_IOVaaKHPxfs7lBdtgWYO8Crs57nV90g 2171
ezetl/examples/reader/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
ezetl/examples/reader/read_csv.py sha256=Pe34BE4WIfGLPNmvVFIyKZGBGO8d3OHuivILmOG5lHA 659
ezetl/examples/reader/read_es.py sha256=nusf1GBRllqK35CnVoxfuNkvqw3LUFH2EtLyVRXSqUA 851
ezetl/examples/reader/read_kafka.py sha256=2sUk9Em3vCYlCxCZ4WT1kuGLKe-NA9t603Mr4o_-3Cs 697
ezetl/examples/reader/read_mongodb.py sha256=bi8WtGI9AhmFMzUQCDpPApxjc9Xsl4epkO7qL_Ddvlg 882
ezetl/examples/reader/read_mysql.py sha256=w_PPCt_SDbQlMYhJowT_QoXXnaoXzLM6tFAGyzLfjV0 910
ezetl/examples/reader/read_mysql_binlog.py sha256=X130brCSnEG4D0qw3ANHaLeaR2tPGSnkZJJ_YsWlFFU 848
ezetl/examples/reader/read_n4j.py sha256=sJ6iv0qF_XigOGFs0o6Sb0hHqcG_qx-HN-xodIwyNA0 821
ezetl/libs/__init__.py sha256=47DEQpj8HBSa-_TImW-5JCeuQeRkm5NMpJWZG3hSuFU 0
ezetl/libs/es.py sha256=1F8avQtAgeMR4RU6eZdFysxT07r-VrZbk86lIl0gDUU 10750
ezetl/libs/hdfs.py sha256=AtiE9WhA5SEiGLVXzdXHyN9OqfIvd_MihAxHPYzIjRc 3214
ezetl/libs/ixdb.py sha256=Uk3JxFczxcnPMCQJjgSTAjp_W1GoRDS8x6NJCM3hxM0 4637
ezetl/libs/kafka_utils.py sha256=IcHsQJgbjLV6xP4jxKqq4lf4eG9fo-P0t5pfOkVWd_M 4496
ezetl/libs/n4j.py sha256=FWGYacI2CkXmu7fIHwIJ7fNegBL-eC_AMz4b_SFkbjA 4583
ezetl/libs/prometheus.py sha256=w9skmyBuV9UK9nt4uATPE-0HjmB8UmcJsa6LEuE_A8c 1139
ezetl/transform_algs/__init__.py sha256=LNxUltM58f7clX8E0wzsKV2TZTSAATGQkej011-Xkr0 1125
ezetl/transform_algs/content_algs.py sha256=numXtStTDME5SsuhCLwotEZbdKSy8YwUy9El0aJkauU 6403
ezetl/transform_algs/count_algs.py sha256=W9P176etJfO9N017xCGNJUcyeKyinyvWzSaot6m4Iws 2307
ezetl/transform_algs/filter_algs.py sha256=owEdSNoMqPDPIBHFazn1WN2N0gevfS6J-QfTbPa1zKs 3978
ezetl/transform_algs/map_algs.py sha256=bnaIchL-wwYmvOJOY4MonVR_DU9AuseZDIIX2OIsYgY 10713
ezetl/utils/__init__.py sha256=PJ8ZJsAhradRO6WWstC13R1wb8nZtY_2-bUh81U1ZOU 2465
ezetl/utils/common_utils.py sha256=w3lftQ8cOZcsC5BuOtshbIFoh1advGF0yjjAGKj2bI0 16329
ezetl/utils/db_utils.py sha256=z3aOfRdmPFZPAh8RhvEF9p0rDAWGyob1o3T435GGEks 6194
ezetl/utils/es_query_tool.py sha256=vLuN_pZHxQFbI1Dx6Yi03yEITkiG2EQL28ojzBvr5v0 22732
ezetl/utils/es_utils.py sha256=L793Q9nRo7imMgH5_B9CHUUUPK48p7hMnj63lXvvWes 2658
ez_etl-1.1.2.dist-info/LICENSE sha256=xx0jnfkXJvxRnG63LTGOxlggYnIysveWIZ6H3PNdCrQ 11357
ez_etl-1.1.2.dist-info/METADATA sha256=TfqP7POBASUz_7YLAuUkewwvdGDH4sv72G-wKwTXmCE 1777
ez_etl-1.1.2.dist-info/WHEEL sha256=ewwEueio1C2XeHTvT17n8dZUJgOvyCWCt0WVNLClP9o 92
ez_etl-1.1.2.dist-info/top_level.txt sha256=Wxn7_-TBkGnhVKmhFa6p8blJWhYDg88HVJWXSEGEDZc 6
ez_etl-1.1.2.dist-info/RECORD

top_level.txt

ezetl