文件名称：beam-mysql-connector:Apache Beam的io连接器，用于访问MySQL数据库
文件大小：37KB
文件格式：ZIP
更新时间：2024-06-06 03:41:33
mysql python pypi apache-beam Python
Beam-MySQL连接器 Beam-MySQL Connector是的io连接器，用于访问MySQL数据库。 安装 pip install beam-mysql-connector 入门 从MySQL读取 from beam_mysql . connector import splitters from beam_mysql . connector . io import ReadFromMySQL read_from_mysql = ReadFromMySQL ( query = "SELECT * FROM test_db.tests;" , host = "localhost" , database = "test_db" , user = "test" , password = "test" ,
【文件预览】：
beam-mysql-connector-master
----setup.py(2KB)
----.gitignore(2KB)
----Makefile(167B)
----beam_mysql()
--------__init__.py(79B)
--------connector()
----MANIFEST.in(93B)
----Pipfile.lock(48KB)
----setup.cfg(36B)
----docker-compose.yml(304B)
----LICENSE.txt(1KB)
----examples()
--------__init__.py(0B)
--------write_records_pipeline.py(1KB)
--------read_records_pipeline.py(2KB)
----scripts()
--------02_insert_test_data.sql(386B)
--------01_create_test_table.sql(771B)
----README.md(2KB)
----tests()
--------test_write_records_pipeline.py(2KB)
--------__init__.py(0B)
--------helper()
--------test_read_records_pipeline.py(5KB)
--------test_base.py(67B)
----Pipfile(339B)