如何在 AWS REDSHIFT 中使现有列不为空？
How to make an existing column NOT NULL in AWS REDSHIFT?
我通过粘合作业动态创建了一个 table，它运行良好。但是根据新要求，我需要添加一个新列来生成唯一值并且应该是 redshift 中的主键。
我使用 rownum() 函数实现了相同的功能，并且运行良好。但是最新的要求是特定的列应该是主键。
当我尝试这样做时，它要求该列不为空。你知道如何通过 glue job 动态地使列不为空吗？或任何使其不为空的红移查询。
我尝试了所有方法都没有运气。
w = Window().orderBy(lit('A'))
df = timestampedDf.withColumn("row_num", row_number().over(w))
rowNumDf = DynamicFrame.fromDF(df1, glueContext, "df1")
postStep = "begin; ALTER TABLE TAB_CUSTOMER_DATA ALTER COLUMN row_num INTEGER NOT NULL; ALTER TABLE TAB_CUSTOMER_DATA ADD CONSTRAINT PK_1 PRIMARY KEY (row_num); end;"
## @type: DataSink
## @args: [catalog_connection = "REDSHIFT_CONNECTION", connection_options = {"dbtable": "tab_customer_data", "database": "randomdb"}, redshift_tmp_dir = TempDir, transformation_ctx = "datasink4"]
## @return: datasink4
## @inputs: [frame = rowNumDf]
datasink4 = glueContext.write_dynamic_frame.from_jdbc_conf(frame = rowNumDf, catalog_connection = "REDSHIFT_CONNECTION", connection_options = {"dbtable": "TAB_CUSTOMER_DATA", "database": "randomdb", "postactions": postStep}, redshift_tmp_dir = args["TempDir"], transformation_ctx = "datasink4")
job.commit()
我使用以下 link 方法解决了这个问题：
- 添加一个具有默认值且不为空的新列。
- 将旧列值更新为新列。
- 删除旧专栏。
- 使这个新列成为主要列。
https://ubiq.co/database-blog/how-to-remove-not-null-constraint-in-redshift/
我通过粘合作业动态创建了一个 table，它运行良好。但是根据新要求，我需要添加一个新列来生成唯一值并且应该是 redshift 中的主键。
我使用 rownum() 函数实现了相同的功能，并且运行良好。但是最新的要求是特定的列应该是主键。
当我尝试这样做时，它要求该列不为空。你知道如何通过 glue job 动态地使列不为空吗？或任何使其不为空的红移查询。 我尝试了所有方法都没有运气。
w = Window().orderBy(lit('A'))
df = timestampedDf.withColumn("row_num", row_number().over(w))
rowNumDf = DynamicFrame.fromDF(df1, glueContext, "df1")
postStep = "begin; ALTER TABLE TAB_CUSTOMER_DATA ALTER COLUMN row_num INTEGER NOT NULL; ALTER TABLE TAB_CUSTOMER_DATA ADD CONSTRAINT PK_1 PRIMARY KEY (row_num); end;"
## @type: DataSink
## @args: [catalog_connection = "REDSHIFT_CONNECTION", connection_options = {"dbtable": "tab_customer_data", "database": "randomdb"}, redshift_tmp_dir = TempDir, transformation_ctx = "datasink4"]
## @return: datasink4
## @inputs: [frame = rowNumDf]
datasink4 = glueContext.write_dynamic_frame.from_jdbc_conf(frame = rowNumDf, catalog_connection = "REDSHIFT_CONNECTION", connection_options = {"dbtable": "TAB_CUSTOMER_DATA", "database": "randomdb", "postactions": postStep}, redshift_tmp_dir = args["TempDir"], transformation_ctx = "datasink4")
job.commit()
我使用以下 link 方法解决了这个问题：
- 添加一个具有默认值且不为空的新列。
- 将旧列值更新为新列。
- 删除旧专栏。
- 使这个新列成为主要列。
https://ubiq.co/database-blog/how-to-remove-not-null-constraint-in-redshift/