canal-python
canal-python copied to clipboard
demo 几个调整建议
1、 # 原代码连等式会造成before 和 after的值全部都是after的值,需分别创建字典。 format_data['before'] = dict() format_data['after'] = dict() ''' format_data['before'] = format_data['after'] = dict() ''' 2、 if event_type == EntryProtocol_pb2.EventType.DELETE: for column in row.beforeColumns: # 原代码只能记录记录的最后一个字段,需做一下更改,这样可以显示所有字段 format_data[column.name] = column.value ''' format_data = { column.name: column.value } ''' elif event_type == EntryProtocol_pb2.EventType.INSERT: for column in row.afterColumns: # 原代码只能记录记录的最后一个字段,需做一下更改,这样可以显示所有字段 format_data[column.name] = column.value ''' format_data = { column.name: column.value } '''