Загрузите пакетные / массовые данные из MYSQL в Kinesis - PullRequest
Новая
       43

Загрузите пакетные / массовые данные из MYSQL в Kinesis

0 голосов
/ 28 мая 2020

Я хочу загружать данные из mysql в Kinesis, только если я запустил запрос выбора из PHPMYADMIN. Для этого я написал код в Python, но не смог найти правильный logi c для этого. Может кто-нибудь помочь мне. Я новичок в AWS. Я использую "only_events = [QueryEvent]" в коде. 

 stream = BinLogStreamReader(
           connection_settings=connection,
           only_events=[QueryEvent],
           server_id=100,
           blocking=True,
           log_file='mysql-bin.000003',
           resume_stream=True,
           )
  for binlogevent in stream:
    def _dump(self):
        super(QueryEvent, self)._dump()
        print("Schema: %s" % (self.schema))
        print("Execution time: %d" % (self.execution_time))
        print("Query: %s" % (self.query))       
        kinesis.put_record(StreamName="MysqlKinesisStream", 
Data=json.dumps(event,cls=DateTimeEncoder), PartitionKey="default",)
        print (json.dumps(event,cls=DateTimeEncoder))
...