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]

此條目有幫助嗎？