AttributeError：'Connection'对象没有属性'setdefault'|| self .__ connection_settings.setdefault（“ charset”，“ utf8”）

Question

我遇到错误。找不到。请帮助我找到它。预先感谢。

文件“ /home/ec2-user/my_app/env/lib64/python3.7/site-packages/pymysqlreplication/binlogstream.py”，行178，在[[init]]中self .__ connection_settings.setdefault（“ charset”，“ utf8”）AttributeError：“连接”对象没有属性“ setdefault”

import json
import boto3
import pymysql
import socket,array
import pandas as pd
from pymysqlreplication import BinLogStreamReader
from pymysqlreplication.row_event import (
   DeleteRowsEvent,
   UpdateRowsEvent,
   WriteRowsEvent,
)
connection = pymysql.connect(host='127.0.0.1',user='root',password='root')

def main():
  kinesis = boto3.client("kinesis",region_name='ap-south-1')
  stream = BinLogStreamReader(
            connection_settings=connection,
            only_events=[DeleteRowsEvent, WriteRowsEvent, UpdateRowsEvent],
            only_schemas=["test"],
            log_file='mysql-bin.000003',
            log_pos=2566,
           server_id=100)
  for binlogevent in stream:
    for row in binlogevent.rows:
       event = {"schema": binlogevent.schema,
       "table": binlogevent.table,
       "type": type(binlogevent).__name__,
       "row": row
       }       
      kinesis.put_record(StreamName="<TestStream>", Data=json.dumps(event), PartitionKey="default",)
      print (json.dumps(event))
if __name__ == "__main__":
   main()

我遇到错误。找不到。请帮助我找到它。提前致谢。文件“ /home/ec2-user/my_app/env/lib64/python3.7/site-packages/pymysqlreplication/binlogstream.py”，第178行，...

Answer 1

connection应该是字典。例如：