Amazon S3 Tables¶

Create an Amazon S3 Table¶

To create a new Iceberg table in an Amazon S3 Tables namespace you can use S3TablesCreateTableOperator.

tests/system/amazon/aws/example_s3_tables.py[source]

create_table = S3TablesCreateTableOperator(
    task_id="create_table",
    table_bucket_arn=bucket_arn,
    namespace=namespace,
    table_name=table_name,
    metadata=SCHEMA,
)

Delete a Table¶

To delete a table from an Amazon S3 Tables namespace, use S3TablesDeleteTableOperator.

tests/system/amazon/aws/example_s3_tables.py[source]

delete_table = S3TablesDeleteTableOperator(
    task_id="delete_table",
    table_bucket_arn=bucket_arn,
    namespace=namespace,
    table_name=table_name,
    trigger_rule=TriggerRule.ALL_DONE,
)