Formed in 2009, the Archive Team (not to be confused with the archive.org Archive-It Team) is a rogue archivist collective dedicated to saving copies of rapidly dying or deleted websites for the sake of history and digital heritage. The group is 100% composed of volunteers and interested parties, and has expanded into a large amount of related projects for saving online and digital history.
Join GitHub today
GitHub is home to over 50 million developers working together to host and review code, manage projects, and build software together.
Sign up[Question] Asynchronous NOTIFY listener #567
Open
Comments
tomkp75
changed the title
|
This should do the trick: conn.add_listener(
'CHANNEL',
functools.partial(asyncio.ensure_future, async_callback()),
) |
|
Thanks. Would it be an idea for add_listener to take in an awaitable directly? |
|
I ended up with something like this: async def listener(self):
async def process(*args):
print(args)
# await self.q.put(args)
if not self.conn_listen:
self.conn_listen = await asyncpg.connect(dsn)
await self.conn_listen.add_listener('my_notify_channel',
lambda *args: loop.create_task(process(args))
)
def main():
listener_task=loop.create_task(listener())
loop.run_forever() |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Hello,
How would one use an async function as the callback of
conn.add_listener? I would like to relay specific notifications to API calls usingaiohttp.ClientSession.Thanks,
Tom