報錯內容：
C:\Users\ecej\AppData\Local\Programs\Python\Python39\python.exe C:/Users/ecej/AppData/Local/Temp/runEtlMysql.py/main.py
Traceback (most recent call last):
File "C:\Users\ecej\AppData\Local\Temp\runEtlMysql.py\main.py", line 6, in <module>
reader = DatabaseReader(src, table_name="gctest")
File "C:\Users\ecej\AppData\Local\Programs\Python\Python39\lib\site-packages\pyetl\reader.py", line 39, in __init__
super().__init__(db)
File "C:\Users\ecej\AppData\Local\Programs\Python\Python39\lib\site-packages\pyetl\connections.py", line 18, in __init__
self.db = connect(driver=db)
File "C:\Users\ecej\AppData\Local\Programs\Python\Python39\lib\site-packages\pydbclib\__init__.py", line 21, in connect
return Database(driver_class(*args, **kwargs))
File "C:\Users\ecej\AppData\Local\Programs\Python\Python39\lib\site-packages\pydbclib\drivers.py", line 90, in __init__
self.compiler = compilers[self.dbapi.paramstyle]
AttributeError: module 'pymysql.connections' has no attribute 'paramstyle'
我的代碼
import pymysql
from pyetl import Task, DatabaseReader, DatabaseWriter, ElasticsearchWriter, FileWriter
src = pymysql.connect(host="xxxxx", port=3306, user="xx", password="xxxxxx", db="xxx")
reader = DatabaseReader(src, table_name="gctest")
# 資料庫之間資料同步，表到表傳輸
dst = pymysql.connect(host="xxx", port=xx, user="xx", password="xxx", db="xxx")
writer = DatabaseWriter(dst, table_name="gctest")
Task(reader, writer).start()
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/208619.html