search

julien-duponchelle / python-mysql-replication

Pure Python Implementation of MySQL replication protocol build on top of PyMYSQL
2.33k stars 679 forks source link

add: send mysql_to_rabbitmq.py #547

Closed myminju closed 1 year ago

myminju commented 1 year ago

closes #545

dongwook-chan commented 1 year ago

I'm gonna test this on local RabbitMQ

dongwook-chan commented 1 year ago

I have tested your code thoroughly. It works fine in general. However in cases where the column types are temporal (i.e. timestamp or datetime) or JSON, I got serialization issues. So I updated to code so that the incompatible column values can be cast to str before being serialized to JSON.