canal-python

canal-python copied to clipboard

client.subscribe(client_id=b'1001', destination=b'example', filter=b'.*\\.(name1|name2)') filter中的没起作用

xulehexuwei

Bumps [protobuf](https://github.com/protocolbuffers/protobuf) from 3.9.1 to 3.18.3. Release notes Sourced from protobuf's releases. Protocol Buffers v3.18.3 C++ Reduce memory consumption of MessageSet parsing This release addresses a Security Advisory for C++...

dependabot[bot]

建立与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 =...

EbonexDev

https://github.com/bithaolee/canal-python 最后的代码示例 问题修改反馈 1. 只打印了最后一个字段 format_data每次都重新赋值而不是追加 ``` format_data = dict() 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...

zhugw

Bumps [certifi](https://github.com/certifi/python-certifi) from 2019.6.16 to 2022.12.7. Commits 9e9e840 2022.12.07 b81bdb2 2022.09.24 939a28f 2022.09.14 aca828a 2022.06.15.2 de0eae1 Only use importlib.resources's new files() / Traversable API on Python ≥3.11 ... b8eb5e9 2022.06.15.1...

dependabot[bot]