How to parse logical replication commands

Question

Code

do $$BEGIN
perform pg_create_logical_replication_slot('test', 'pgoutput', false);
END$$ ;
create publication Jalgi_pub for all tables;
select * from pg_logical_slot_peek_binary_changes('test', null, null,'proto_version', '4', 'publication_names', 'Jalgi_pub' )

returns replication commands as binary content in Data column. How to convert this data to sql commands like insert, update, delete ?

Using C#, npgsql, ef core and ASP.NET MVC. Can some npgsql method uses for this? Or is it possible to create replication which returns this data as replication messages? Or can binry replcaton used

Answer 1

You have to use plugins which does the task of converting wal events to sql queries.One such plugin is decoder_raw
https://github.com/michaelpq/pg_plugins/blob/main/decoder_raw/decoder_raw.c
Install it and create slot with this plugin.