PG Channels

Python wrapper for PostgreSQL NOTIFY and LISTEN commands.

Installation

pip install pg_channels

Usage

First, establish a connection to the PostgreSQL database:

import pg_channels

pgc = pg_channels.connect(host='localhost', database='mydb')

Sending notification events:

pgc.notify('channel_one', 'Some data')

Subscribing to a channel and and handling notification events:

# Subscribe (listen) to a specific channel
pgc.listen('channel_two')

# Iterate over any notification events
for event in pgc.events():
	some_func(event.payload)