`airflow.providers.amazon.aws.hooks.dynamodb`¶

此模块包含 Amazon DynamoDB Hook。

模块内容¶

类¶

与 Amazon DynamoDB 交互。

class airflow.providers.amazon.aws.hooks.dynamodb.DynamoDBHook(*args, table_keys=None, table_name=None, **kwargs)[源代码]¶

基类: airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

与 Amazon DynamoDB 交互。

提供 boto3.resource("dynamodb") 的厚包装。

参数

table_keys (list | None) – 分区键和排序键
table_name (str | None) – 目标 DynamoDB 表

可以指定其他参数（例如 aws_conn_id），这些参数将传递给底层的 AwsBaseHook。

另请参阅

airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

client()[源代码]¶

返回 boto3 客户端。

write_batch_data(items)[源代码]¶

使用预配置的吞吐量容量将批量项目写入 DynamoDB 表。

另请参阅

参数: items (collections.abc.Iterable) – DynamoDB 项目列表。

get_import_status(import_arn)[源代码]¶

从 Dynamodb 获取导入状态。

参数: import_arn (str) – 导入的 Amazon 资源名称 (ARN)。
返回: 导入状态、错误代码和错误消息
返回类型: tuple[str, str | None, str | None]

此条目是否有帮助？