airflow.providers.amazon.aws.hooks.dynamodb

此模块包含 Amazon DynamoDB Hook。

类

DynamoDBHook

与 Amazon DynamoDB 交互。

模块内容

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

基类: 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。

另请参阅

table_keys = None[source]
table_name = None[source]
property client: botocore.client.BaseClient[source]

返回 boto3 客户端。

write_batch_data(items)[source]

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

另请参阅

参数：

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

get_import_status(import_arn)[source]

从 Dynamodb 获取导入状态。

参数：

import_arn (str) – 导入的 Amazon Resource Name (ARN)。

返回：

导入状态、错误码和错误消息

返回类型：

tuple[str, str | None, str | None]

此条目有帮助吗？