Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

Vertica 连接

在 Amazon Glue 4.0 及更高版本中，您可以使用 Amazon Glue for Spark 来读取和写入 Vertica 中的表。您可以使用 SQL 查询来定义要从 Vertica 中读取的信息。您可以通过 Amazon Glue 连接并使用存储在 Amazon Secrets Manager 中的用户名和密码凭证连接到 Vertica。

有关 Vertica 的更多信息，请参阅 Vertica 文档。

配置 Vertica 连接

要从 Amazon Glue 连接到 Vertica，您需要创建 Vertica 凭证并将其存储在某个 Amazon Secrets Manager 密钥中，然后将该密钥关联到某个 Vertica Amazon Glue 连接。如果您的 Vertica 实例位于某个 Amazon VPC 中，则还需要提供 Amazon Glue Vertica 连接的联网选项。您需要提供读取和写入数据库时用于临时存储的 Amazon S3 存储桶或文件夹。

要从 Amazon Glue 连接到 Vertica，您将需要满足一些先决条件：

然后您可以继续配置 Amazon Glue 以便与 Vertica 配合使用。

创建 Amazon Glue Vertica 连接后，您需要执行以下操作，然后才能调用您的连接方法：

从 Vertica 读取

先决条件：

例如：

dynamicFrame = glueContext.create_dynamic_frame.from_options(
    connection_type="vertica",
    connection_options={
        "connectionName": "connectionName",
        "staging_fs_url": "s3a://tempS3Path",
        "db": "dbName",
        "table": "tableName",
    }
)

您还可以提供 SELECT SQL 查询来筛选返回到 DynamicFrame 的结果，或者访问来自多个表的数据集。

例如：

dynamicFrame = glueContext.create_dynamic_frame.from_options(
    connection_type="vertica",
    connection_options={
        "connectionName": "connectionName",
        "staging_fs_url": "s3a://tempS3Path",
        "db": "dbName",
        "query": "select * FROM tableName",
    },
)

写入 Vertica 表

此示例会将来自现有 DynamicFrame dynamicFrame 的信息写入 Vertica。如果表中已经含有信息，Amazon Glue 会将来自 DynamicFrame 的数据附加到现有信息之后。

先决条件：

例如：

glueContext.write_dynamic_frame.from_options(
    frame=dynamicFrame,
    connection_type="vertica",
    connection_options={
        "connectionName": "connectionName",
        "staging_fs_url": "s3a://tempS3Path",
        "db": "dbName",
        "table": "tableName",
    }
)

Vertica 连接选项参考