Psycopg2 是否允许使用 Python 在 redshift 上运行 udf create 查询？

Question

我可以使用 python 通过 psycopg2 连接到 aws-redshift，我可以查询表并取回数据等...

但是，当我尝试通过 psycopg2 运行 create udf 函数时，没有任何反应，没有错误返回，但没有创建任何内容。

这是我的代码：

def _applyFunctionToDB():
    con=psycopg2.connect(dbname = redhsiftDatabase, host = redshiftHost, port = '5439', user = redshiftUser, password = redshiftPwd)
    cur = con.cursor()
    udf=_fileOpenWrite(udfFile)
    size = os.stat(udfFile).st_size
    udfCode=udf.read(size)
    cur.execute(udfCode)
    con.close()

我已经通过调试器运行它并且所有部分都在那里，但是当在光标上调用“执行”方法时没有任何反应。

如果有人对这里可能发生的事情有任何建议和/或想法，请提出建议。

谢谢！

Answer 1

在此处发布后找到答案：Copying data from S3 to AWS redshift using python and psycopg2

我需要调用一个提交。

所以，在上面的代码中执行后添加con.commit。