-
Notifications
You must be signed in to change notification settings - Fork 784
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
SQL Change Data Capture #82
Comments
Hey @marceloboeira, this sounds very similar to another MySQL based input we're looking at: #76 The current plan is to add it in as a plugin, the API for which is ready to use but some plumbing is still pending for generating configuration examples and documentation etc. I'd be interested in adding this as another plugin so your configuration would look something like this: input:
type: pgsql
plugin:
... pgsql config fields here ... If you can wait a few days for me to get the MySQL input merged you'll end up with a good example to base yours on. |
Blocked on: #83 |
@marceloboeira I have an example plugin you can check out here: https://github.com/Jeffail/benthos/blob/feature/plugin-example/lib/input/plugins/mysql.go#L48 Let me know what you think of the |
Hey I am trying to use Benthos to parse database logs ( WAL)...for Oracle, mySQL, PostreSQL
The link above is dead. "Shes dead jim, shes dead"
|
Hey @gedw99, the plugin examples can now be found here: https://github.com/benthosdev/benthos-plugin-example, but there isn't one for WAL I'm afraid. |
thanks all for the update. Yeah playing with the following stuff to do this over at https://github.com/14-bits/cdc. The plan is to get it working with benthos, but lots of database parsing to do first. Playing around with these libs to do CDC ( Change Capture Control) of the databases to feed into Benthos.
https://github.com/wal-g/wal-g
https://github.com/moiot/gravity
|
Since this is a fairly high demand topic I'm repurposing this issue for a general revisit of SQL CDC within Benthos. CDC is handled very differently across databases and therefore we have two options:
Ideally I wouldn't want to burden the Benthos project with actively maintaining these inputs, and would therefore prefer to utilize a library that is intended to be consumed similar to a typical stream client library. To start this one off I'd like for us to do another search for Go libraries in this space since a fair amount of time has passed. |
Think implementing CDC in Benthos would be a great step forward and it would attract new users. I was looking at some projects and here are some I liked: |
Another repo to check out (from #570): https://github.com/tmc/pqstream |
I don't need support for this (yet), but did some quick digging and thought that mixing Benthos with https://github.com/prest/prest might be interesting. |
In the direction of per database connections, here is another lib that handles postgres logical decoding well: I liked what pgdeltastream is doing as well. Main difference between the two is pgoutput creates the replication slot with the plugin |
I've been testing out wal-listener quite extensively the last 24h. I think it would be an incredibly nice feature in benthos to have a similar interface. |
Also look at Conduit project and their postgres connector. |
Likewise conduit's vitess/mysql connector |
We have a project at the company I work where we connect to PgSQL using a logical replication slot to receive all data changes (insert, update, delete) for a configurable set of tables
and stream data directly from the database to streams (in our case kinesis). We do that using PgSQL WAL.
That's used for multiple reasons, faning-out to an ES instance from multiple sources, metrics/statistics collection, as well as data-warehousing e.g.: using kinesis firehose...
So, we have implemented similar things to benthos, in regards to acknowledgement and sinks. Yet, since our code is also written in go, moving forward, it would be easier for us to contribute to benthos, by adding support to PgSQL, rather than re-implementing lots of things you have already created.
It could be an interesting addition, since we could stream either events and data from the database.
I would like to hear the maintainers opinion on this, if it's something you're interested in I could work on a PR base.
The text was updated successfully, but these errors were encountered: