尝试使用 Python 和 psycopg2 创建 Redshift 表，但未创建表且未报告错误

Question

我的代码没有返回错误，但我在 Redshift 中没有看到表...如果我输入“如果表存在”并尝试创建一个我知道存在的表，它什么也不做，也不返回任何错误。把它拿出来，它会返回奇怪的可重复错误。

import boto3
import psycopg2
import sys

#Assign global variables data needed to make connection to Redshift
DB_NAME = '<database>'
CLUSTER_IDENTIFIER = '<clusterName>'
DB_USER = '<user>'
ENDPOINT = '<clustername>.<randomkey>.us-east-1.redshift.amazonaws.com'
REGION = 'us-east-1'

sql = "CREATE TABLE if not exists " + "<schema>.<tablename> " + \
      "( vendorid varchar(4), pickup_datetime TIMESTAMP, " + \
      "dropoff_datetime TIMESTAMP, store_and_fwd_flag varchar(1), " + \
      "ratecode int, pickup_longitude float(4), pickup_latitude float(4)," + \
      "dropoff_logitude float(4), dropoff_latitude float(4), " + \
      "passenger_count int, trip_distance float(40), fare_amount float(4), " + \
      "extra float(4), mta_tax float(4), tip_amount float(4), " + \
      "tolls_amount float(4), ehail_fee float(4), improvement_surcharge float(4), " + \
      "total_amount float(4), payment_type varchar(4), trip_type varchar(4))  " + \
      "DISTSTYLE EVEN SORTKEY (passenger_count, pickup_datetime);"

try:
    #make redshift connection
    client = boto3.client('redshift', region_name='us-east-1')

    #get temporary username and password
    cluster_creds = client.get_cluster_credentials(DbUser=DB_USER, DbName=DB_NAME, ClusterIdentifier=CLUSTER_IDENTIFIER, AutoCreate=False)
    temp_user = cluster_creds['DbUser']
    temp_pswd = cluster_creds['DbPassword']

    #create connection string to database
    conn = psycopg2.connect(f"host='{ENDPOINT}' port='5439' user={temp_user} password={temp_pswd} dbname='{DB_NAME}'")

    #Attempt to create table
    cursor = conn.cursor()
    cursor.execute(sql)
    conn.commit
    cursor.close()
    conn.close()

    #report any errors
except Exception as ex:
    print("Exception name : " + ex.__class__.__name__)
    print(str(ex))
    print("Failed to open connection to Redshift database")
    sys.exit(1)

Answer 1

我的代码没有返回错误，但我在 Redshift 中没有看到表...如果我输入“如果表存在”并尝试创建一个我知道存在的表，它什么也不做，也不返回任何错误。把它拿出来，它会返回奇怪的重复错误。

code 或 redshift 没有问题。无论发生什么都在意料之中。

如果我输入“如果表存在”并尝试创建一个我知道存在的表，它什么也不做并且不返回错误

这是根据 Redshift documentation 预期的。它没有错。以下是if not exist 的文档摘录。

如果不存在

指示如果指定的表已经存在的子句，命令应该不做任何更改并返回表存在的消息，而不是以错误终止。请注意，现有表可能与已创建的表完全不同；只有表名用于比较。

此子句在编写脚本时很有用，因此如果 CREATE TABLE 尝试创建已存在的表，脚本不会失败。

取出它，它会返回奇怪的重复错误。

它的预期，表已经存在，因此duplicate table error。

我在 Redshift 中没有看到表格

这应该是您用来查看表的用户没有查看该表的权限或错误地查看其他数据库的问题。 为了证明我的观点，表存在，尝试使用您的程序在表中插入一些记录并尝试选择这些记录，如果发生这种情况，则证明表存在并且具有数据。您可能用来查看表格的其他用户可能没有查看表格的权限。

希望对你有帮助。