EbonexDev

建立与Canal的连接代码bug

1

if event_type == EntryProtocol_pb2.EventType.DELETE: for column in row.beforeColumns: **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 =...