import asyncio
import aiopg
import primesieve

async def put_prime(loop):
    dsn = 'dbname=mydb user=postgres password=dbpassword host=127.0.0.1'
    async with aiopg.create_pool(dsn) as pool, pool.acquire() as conn, conn.cursor() as cur:
         it = primesieve.Iterator()
         while True:
             await cur.execute("NOTIFY prime, %s", [str(it.next_prime())])
             await asyncio.sleep(5)

if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    loop.run_until_complete(put_prime(loop))
    loop.close()