【文件属性】：
文件名称：beam-mysql-connector:Apache Beam的io连接器，用于访问MySQL数据库
文件大小：37KB
文件格式：ZIP
更新时间：2021-05-17 09:54:53
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)