AWS Redshift表查询正常 从Lambda插入数据无报错被中止如何解决

最高优先级修复：补充事务提交 #

psycopg2默认关闭自动提交，所有写操作（INSERT/UPDATE/DELETE）执行后必须显式调用conn.commit()，否则关闭连接时事务会自动回滚，不会持久化数据，也不会抛出错误。
在你现有代码的cur.execute()执行后、cur.close()前添加conn.commit()即可，修改后的核心逻辑如下：

cur.execute("INSERT INTO public.summaries(topic,summary) values('data', 'data_summary');")
# 新增事务提交语句
conn.commit()
cur.close()
conn.close()

其他问题排查方向 #

• 账号权限校验：确认连接使用的数据库账号拥有public.summaries表的INSERT权限，SELECT权限与INSERT权限独立，可使用同一账号在本地客户端执行相同INSERT语句验证，如本地执行失败，执行授权语句：GRANT INSERT ON public.summaries TO 你的数据库用户名;
• 异常捕获完善：现有代码未做异常捕获，可能出现的运行时错误被吞没有输出，建议添加try-except块捕获并打印全量错误日志，同时推荐使用参数化查询避免SQL注入风险，参考代码如下：

import psycopg2
import traceback

try:
    conn = psycopg2.connect(
        dbname = 'dev',
        host = 'redshift-cluster-summaries.c0xcgwtgz65l.us-east-2.redshift.amazonaws.com',
        port = '5439',
        user = '****',
        password = '****%'
    )
    cur = conn.cursor()
    # 参数化查询写法
    cur.execute("INSERT INTO public.summaries(topic,summary) VALUES(%s, %s);", ('data', 'data_summary'))
    conn.commit()
    print(f"插入成功，影响行数：{cur.rowcount}")
    cur.close()
    conn.close()
except Exception as e:
    print(f"操作异常：{str(e)}")
    print("异常栈信息：", traceback.format_exc())
    # 异常时回滚事务
    if 'conn' in locals() and not conn.closed:
        conn.rollback()
        cur.close()
        conn.close()

• Redshift侧查询验证：登录Redshift控制台的查询监控界面，定位对应INSERT语句的执行记录，查看执行状态、错误码、是否存在锁等待或资源不足被终止的情况。
• Lambda配置排查：确认Lambda超时时间大于INSERT操作的实际执行时长，同时如果使用IAM权限管控，确认Lambda执行角色拥有对应的Redshift操作权限。

内容的提问来源于stack exchange，提问作者luis programming