Alin Panaitiu alin23

alin23 / listen.py

Last active September 4, 2020 17:03 — forked from kissgyorgy/listen.py

How to use PostgreSQL's LISTEN/NOTIFY as a simple message queue with psycopg2 and asyncio

	import asyncio
	import psycopg2

	# dbname should be the same for the notifying process
	conn = psycopg2.connect(host="localhost", dbname="example", user="example", password="example")
	conn.set_isolation_level(psycopg2.extensions.ISOLATION_LEVEL_AUTOCOMMIT)

	cursor = conn.cursor()
	cursor.execute(f"LISTEN match_updates;")