python-3.x - 执行 select pg_notify 的 Python psycopg2 不起作用

Question

这是我在 StackOverflow 的第一个问题，所以如果我做错了什么，请保持温和。

我正在努力从 Python 脚本执行 SELECT pg_notify。好像根本就不行。

我的 NodeJS 服务器正在使用 pg-promise 监听“testnotify” channel 。我只是为了完整起见，因为它正在工作。

db.connect({direct: true})
.then(sco => {
    sco.client.on('notification', data => {
        console.log('Received:', data);
    });
    return sco.none('LISTEN $1~', 'testnotify');
})
.catch(error => {
    console.log('Error:', error);
});

我的 Python 脚本应该在一系列成功的数据库操作后发出通知。

我是这样做的

conn = psycopg2.connect(conn_string)
cur = conn.cursor()
cur.execute("SELECT pg_notify('%s', '%s');" % ('testnotify', 'blabla'))

或者那样

query = "SELECT pg_notify('testnotify', 'blabla');"
print(query)
cur.execute(query)

我以类似的方式尝试过 NOTIFY testnotify, 'blabla' 但没有任何效果。 NodeJS 方面什么也没有发生。但是当我从 Python 控制台复制打印(查询)的结果并直接从 PostgreSQL 执行它时，它就像一个魅力。我不明白我的代码有什么问题。

我在 Windows 10 上使用 psycopg2 2.7.5、PostgreSQL 10、Node 10 LTS、pg-promise。

旁注:这不是 Node 的问题，因为当 pg_notify 或 notify 在 postgresql 中的源表中使用触发器引发时，或者在 db 中作为常规 sql 查询执行通知时，它正在工作。它仅在我尝试从 python 脚本发出通知时不工作。

经过两天的折腾，我认为这是显而易见且愚蠢的事情，但我看不到它。或者，也许这是不可能的...

请帮忙。

Answer 1

哦，天哪……我刚刚找到了解决方案……甚至有两种方法可以解决这个问题。

线索在 psycopg 文档中……很明显吧？

使用

发送通知

cur.execute("SELECT pg_notify('%s', '%s');" % ('testnotify', 'blabla'))

必须像那样设置连接以自动提交

import psycopg2
import psycopg2.extensions
conn.set_isolation_level(psycopg2.extensions.ISOLATION_LEVEL_AUTOCOMMIT)

或者如果你不想自动提交那么在做完之后

cur.execute("SELECT pg_notify('%s', '%s');" % ('testnotify', 'blabla'))

你必须提交它

conn.commit()

现在 Node 正在通过 python 接收来自 postgresql 的通知