What's the correct way of creating listeners using a connection pool?

[theo-brown]

I have a connection pool that exists for the duration of my program.
I want to add a listener to a NOTIFY channel, my_channel, that runs my_callback_function.

What's the correct way of doing this? I need to avoid the listener_connection from being garbage collected.

My current approach:

listener_connection = await pool.acquire()
await listener_connection.add_listener('my_channel', my_callback_function)
...
# Program performs many other database operations, acquiring new connections from the pool as required.
...

[elprans]

That's the correct way. If you want something to live in Python, you must keep a reference to it. Most frameworks have a global state object you can write to (e.g. app in Flask).

[theo-brown]

So for example, if I was doing this within a class, I could do:

...
self.listeners = []
listener_connection = await self.pool.acquire()
await listener_connection.add_listener('my_channel', my_callback_function)
self.listeners.append(listener_connection)
...

Is that correct?

[elprans]

As long as the class instance lives long enough, yes.