MIME-Version: 1.0
References: <CAKeSjMjBTxSVHq==8UuNBwAXjDC+vonsdJEd3TndN2-PP=NzpQ@mail.gmail.com>
In-Reply-To: <CAKeSjMjBTxSVHq==8UuNBwAXjDC+vonsdJEd3TndN2-PP=NzpQ@mail.gmail.com>
From: Justin <zzzzz.graf@gmail.com>
Date: Fri, 21 Feb 2025 16:45:16 -0500
Message-ID: <CALL-XeN2qJRByqywoJ5YKVBxVoboNmPGRp9uYQEWZU4U1wmTdw@mail.gmail.com>
Subject: Re: Logical decoding
To: Jethish Jethish <jethish777@gmail.com>
Cc: pgsql-general@lists.postgresql.org
Content-Type: multipart/alternative; boundary="000000000000af9c47062eade8b3"
Archived-At: <https://www.postgresql.org/message-id/CALL-XeN2qJRByqywoJ5YKVBxVoboNmPGRp9uYQEWZU4U1wmTdw%40mail.gmail.com>
Precedence: bulk

--000000000000af9c47062eade8b3
Content-Type: text/plain; charset="UTF-8"
Content-Transfer-Encoding: quoted-printable

On Thu, Feb 20, 2025 at 12:04=E2=80=AFAM Jethish Jethish <jethish777@gmail.=
com>
wrote:

> Hi everyone,
>
> Is there is any option to perform logical decoding on an active
> replication slot.
> I'm trying to decode a replication slot but it throughs an error as below=
.
>
> ERROR: replication slot "my_sub" is active for PID 2525720
>


Hi Jethish,

You can by copying the LR slot

SELECT  pg_copy_logical_replication_slot ( '<slot_name>', --source slot
'peek', --destination slot name
true,  --lets make a temporary slot, so we don't have clean up after
ourselves
'test_decoding' --plugin name can be any LR plugin this one let's us see
what is going on
)

Then peek at what the slot is doing

SELECT * FROM pg_logical_slot_peek_changes('peek' , --name of the slot
NULL, --lsn number to start from  can jump ahead,
1 ); --how many transaction to get back from the query this will return
multiple rows for each row affect by the transaction.

select pg_drop_replication_slot(<slot_name>)  --how we drop the slot

--000000000000af9c47062eade8b3
Content-Type: text/html; charset="UTF-8"
Content-Transfer-Encoding: quoted-printable

<div dir=3D"ltr"><div dir=3D"ltr"><br></div><div class=3D"gmail_quote gmail=
_quote_container"><div dir=3D"ltr" class=3D"gmail_attr">On Thu, Feb 20, 202=
5 at 12:04=E2=80=AFAM Jethish Jethish &lt;<a href=3D"mailto:jethish777@gmai=
l.com">jethish777@gmail.com</a>&gt; wrote:<br></div><blockquote class=3D"gm=
ail_quote" style=3D"margin:0px 0px 0px 0.8ex;border-left:1px solid rgb(204,=
204,204);padding-left:1ex"><div dir=3D"auto">Hi everyone,<div dir=3D"auto">=
<br></div><div dir=3D"auto">Is there is any option to perform logical decod=
ing on an active replication slot.</div><div dir=3D"auto">I&#39;m trying to=
 decode a replication slot but it throughs an error as below.</div><div dir=
=3D"auto"><br></div><div dir=3D"auto">ERROR: replication slot &quot;my_sub&=
quot; is active for PID 2525720</div></div></blockquote><div><br></div><div=
><br></div>Hi Jethish,<br><br>You can by copying=C2=A0the LR slot=C2=A0<br>=
<br>SELECT =C2=A0pg_copy_logical_replication_slot ( &#39;&lt;slot_name&gt;&=
#39;, --source slot<br>										&#39;peek&#39;, --destination slot name<br=
>										true, =C2=A0--lets make a temporary slot, so we don&#39;t have c=
lean up after ourselves=C2=A0<br>										&#39;test_decoding&#39; --plugin=
 name can be any LR plugin=C2=A0this one let&#39;s us see what is going on<=
br>)<br><br>Then peek at what the slot is doing<br><br>SELECT * FROM pg_log=
ical_slot_peek_changes(&#39;peek&#39; , --name of the slot<br>			 								N=
ULL, --lsn number to start from =C2=A0can jump ahead,<br>										 1 ); --=
how many transaction to get back from the query this will return multiple r=
ows for each row affect by the transaction.=C2=A0<br><br>select pg_drop_rep=
lication_slot(&lt;slot_name&gt;)=C2=A0 --how we drop the slot<br><div>=C2=
=A0</div></div></div>

--000000000000af9c47062eade8b3--