在 Python 中，如何捕获 Redshift 对 COPY 命令的响应？

Question

我使用sqlalchemy pygresql将复制命令发送到redshift，以将csv/json文件导入数据库表。执行复制命令后，在屏幕上发送了一条消息行：

INFO:  Load into table 'o_item_details' completed, 20443 record(s) loaded successfully.

如何捕获此消息，以便将其推入将日志写入文件的记录函数？这是我的代码：

engine = create_engine("postgresql+pygresql://{0}:{1}@{2}:{3}/{4}".format(rs_user, rs_pwd, rs_host, rs_port, rs_dbname))
conn = engine.connect()
re = conn.execute(sql_cmd) 

sql_cmd是复制语句(copy {rs_tbl_name} from s3://{s3_bucket}/{s3_file} ...(

我围绕exultsproxy对象播放了执行函数返回的对象，但找不到检索消息的方法。

任何帮助都非常感谢！

Answer 1

由于stackoverflow不允许简短答案，所以我必须添加您正在阅读的句子：(

print(conn.notices)