The content of the error:
C: \ Users \ ecej \ AppData \ Local \ designed \ Python \ Python39 \ Python exe C:/Users/ecej AppData/Local/Temp/runEtlMysql py/main py
Traceback (the most recent call last) :
The File "C: \ Users \ ecej \ AppData \ Local \ Temp \ runEtlMysql py \ main py", line 6, the in & lt; module>
Reader=DatabaseReader (SRC, table_name="gctest")
File "C: \ Users \ ecej \ AppData \ Local \ designed \ Python \ Python39 \ lib \ site - packages \ pyetl \ reader py", 39, the line in __init__
Super () __init__ (db)
The File "C: \ Users \ ecej \ AppData \ Local \ designed \ Python \ Python39 \ lib \ site - packages \ pyetl \ connections py", line 18, in __init__
The self. The db=connect (driver=db)
File "C: \ Users \ ecej \ AppData \ Local \ designed \ Python \ Python39 \ lib \ site - packages \ pydbclib \ set py", line 21, connect in
Return the Database (driver_class (* args, * * kwargs))
The File "C: \ Users \ ecej \ AppData \ Local \ designed \ Python \ Python39 \ lib \ site - packages \ pydbclib \ drivers py", line 90, in __init__
Self.com piler=compilers [self. Dbapi will work essentially identically. Paramstyle]
AttributeError: module 'pymysql. Connections' has no attribute' paramstyle '
my code
The import pymysql
The from pyetl import Task, DatabaseReader and DatabaseWriter, ElasticsearchWriter, FileWriter
SRC=https://bbs.csdn.net/topics/pymysql.connect (host="XXXXX", the port=3306, user="xx", "=" XXXXXX ", db="XXX")
Reader=DatabaseReader (SRC, table_name="gctest")
# data synchronization between the database and table to table transmission
DST=pymysql. Connect (host="XXX", the port=xx, user="xx", "=" XXX ", db="XXX")
Writer=DatabaseWriter (DST, table_name="gctest")
Task (reader and writer.) start ()