`tests.system.amazon.aws.example_dynamodb_to_s3`¶

模块内容¶

`enable_point_in_time_recovery`(table_name)
`set_up_table`(table_name)
`get_export_time`(table_name)
`wait_for_bucket`(s3_bucket_name)
`delete_dynamodb_table`(table_name)
`incremental_export`(table_name, start_time)	增量导出需要至少 15 分钟的数据导出窗口。

tests.system.amazon.aws.example_dynamodb_to_s3.DAG_ID = 'example_dynamodb_to_s3'[源代码]¶

tests.system.amazon.aws.example_dynamodb_to_s3.S3_KEY_PREFIX = 'dynamodb-segmented-file'[源代码]¶

tests.system.amazon.aws.example_dynamodb_to_s3.enable_point_in_time_recovery(table_name)[源代码]¶

tests.system.amazon.aws.example_dynamodb_to_s3.set_up_table(table_name)[源代码]¶

tests.system.amazon.aws.example_dynamodb_to_s3.get_export_time(table_name)[源代码]¶

tests.system.amazon.aws.example_dynamodb_to_s3.wait_for_bucket(s3_bucket_name)[源代码]¶

tests.system.amazon.aws.example_dynamodb_to_s3.delete_dynamodb_table(table_name)[源代码]¶

tests.system.amazon.aws.example_dynamodb_to_s3.incremental_export(table_name, start_time)[源代码]¶

增量导出需要至少 15 分钟的数据导出窗口。此任务组允许我们在文档中包含示例代码片段，同时在运行实际测试时跳过该任务。