From 2ad7d5f4a72b1291a95242cd50db45efd3a60554 Mon Sep 17 00:00:00 2001 From: Jeremy Yin Date: Fri, 29 Nov 2019 15:16:50 +0800 Subject: [PATCH 1/2] =?UTF-8?q?=E4=BF=AE=E6=AD=A3=20format=5Fdata=20?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E7=BB=84=E8=A3=85=E9=94=99=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- README.md | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/README.md b/README.md index ea3cbb0..6cb5722 100644 --- a/README.md +++ b/README.md @@ -98,15 +98,15 @@ while True: for row in row_change.rowDatas: format_data = dict() if event_type == EntryProtocol_pb2.EventType.DELETE: - for column in row.beforeColumns: - format_data = { - column.name: column.value - } + format_data = { + column.name: column.value + for column in row.beforeColumns + } elif event_type == EntryProtocol_pb2.EventType.INSERT: - for column in row.afterColumns: - format_data = { - column.name: column.value - } + format_data = { + column.name: column.value + for column in row.afterColumns + } else: format_data['before'] = format_data['after'] = dict() for column in row.beforeColumns: From b758b9fa17e08c66600bb9299e7f1d046fc615e0 Mon Sep 17 00:00:00 2001 From: Jeremy Yin Date: Fri, 29 Nov 2019 15:17:38 +0800 Subject: [PATCH 2/2] =?UTF-8?q?=E4=BF=AE=E6=AD=A3=20format=5Fdata=20?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E7=BB=84=E8=A3=85=E9=94=99=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- canal/example.py | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/canal/example.py b/canal/example.py index de68f90..771d3e4 100644 --- a/canal/example.py +++ b/canal/example.py @@ -28,15 +28,15 @@ for row in row_change.rowDatas: format_data = dict() if event_type == EntryProtocol_pb2.EventType.DELETE: - for column in row.beforeColumns: - format_data = { - column.name: column.value - } + format_data = { + column.name: column.value + for column in row.beforeColumns + } elif event_type == EntryProtocol_pb2.EventType.INSERT: - for column in row.afterColumns: - format_data = { - column.name: column.value - } + format_data = { + column.name: column.value + for column in row.afterColumns + } else: format_data['before'] = format_data['after'] = dict() for column in row.beforeColumns: @@ -52,4 +52,4 @@ print(data) time.sleep(1) -client.disconnect() \ No newline at end of file +client.disconnect()