翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

# コネクタと依存関係を使用する
<a name="how-zeppelin-connectors"></a>

コネクタを使用すると、さまざまなテクノロジーにわたってデータの読み書きが可能になります。Apache Flink 用 Managed Service では、Studio ノートブックに 3 つのデフォルトコネクタがバンドルされています。カスタムコネクタを使用することもできます。コネクタの詳細については、Apache Flink ドキュメントの「[テーブルコネクタと SQL コネクタ](https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/connectors/table/overview/)」を参照してください。

## デフォルトコネクター
<a name="zeppelin-default-connectors"></a>

を使用して Studio ノートブック AWS マネジメントコンソール を作成する場合、Apache Flink 用 Managed Service には、デフォルトで `flink-sql-connector-kinesis``flink-connector-kafka_2.12`および のカスタムコネクタが含まれています`aws-msk-iam-auth`。これらのカスタムコネクタを使用せずにコンソールから Studio ノートブックを作成するには、[**カスタム設定で作成**] オプションを選択します。次に、[**Configurations**] ページに移動し、2つのコネクターの横にあるチェックボックスをオフにします。

[CreateApplication](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_CreateApplication.html) API を使用して Studio ノートブックを作成する場合、 `flink-sql-connector-flink` と `flink-connector-kafka` コネクタはデフォルトでは含まれていません。これらを追加するには、以下の例のように `CustomArtifactsConfiguration` データタイプに `MavenReference` を指定します。

この `aws-msk-iam-auth` コネクタは、IAM で自動的に認証する機能を含む、Amazon MSK で使用するコネクタです。

**注記**  
以下の例に示されているコネクタバージョンは、当社がサポートしている唯一のバージョンです。

```
For the Kinesis connector:

"CustomArtifactsConfiguration": [{
"ArtifactType": "DEPENDENCY_JAR",            
   "MavenReference": {
"GroupId": "org.apache.flink",

      "ArtifactId": "flink-sql-connector-kinesis",
      "Version": "1.15.4"

   }      
}]

For authenticating with AWS MSK through AWS IAM:

"CustomArtifactsConfiguration": [{
"ArtifactType": "DEPENDENCY_JAR",            
   "MavenReference": {
"GroupId": "software.amazon.msk",
      "ArtifactId": "aws-msk-iam-auth",
      "Version": "1.1.6"
   }      
}]
            
For the Apache Kafka connector:  

"CustomArtifactsConfiguration": [{
"ArtifactType": "DEPENDENCY_JAR",            
   "MavenReference": {
"GroupId": "org.apache.flink",

      "ArtifactId": "flink-connector-kafka",
      "Version": "1.15.4"

   }      
}]
```

これらのコネクタを既存のノートブックに追加するには、[UpdateApplication](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_UpdateApplication.html) API オペレーションを使用して `CustomArtifactsConfigurationUpdate` データタイプで `MavenReference` を指定します。

**注記**  
テーブル API の `flink-sql-connector-kinesis` コネクタでは、`failOnError`を true に設定できます。

## 依存関係とカスタムコネクタを追加する
<a name="zeppelin-custom-connectors"></a>

を使用して Studio ノートブックに依存関係またはカスタムコネクタ AWS マネジメントコンソール を追加するには、次の手順に従います。

1. カスタムコネクタのファイルを Amazon S3 にアップロードします。

1. で AWS マネジメントコンソール、Studio ノートブックを作成するための**カスタム作成**オプションを選択します。

1. Studio ノートブック作成ワークフローに従って **設定** ステップまで進みます。

1. [**カスタムコネクタ**] セクションで [**カスタムコネクタを追加**] を選択します。

1. 依存関係またはカスタムコネクタの Amazon S3 のロケーションを指定します。

1. **[Save changes]** (変更の保存) をクリックします。

[CreateApplication](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_CreateApplication.html) API を使用して新しい Studio ノートブックを作成するときに、依存 JAR またはカスタムコネクタを追加するには、依存 JAR またはカスタムコネクタの Amazon S3 ロケーションを `CustomArtifactsConfiguration` データタイプにで指定します。既存の Studio ノートブックに依存関係またはカスタムコネクタを追加するには、[UpdateApplication](https://docs.aws.amazon.com/managed-flink/latest/apiv2/API_UpdateApplication.html) API オペレーションを呼び出し、依存 JAR またはカスタムコネクタの Amazon S3 ロケーションを `CustomArtifactsConfigurationUpdate` データタイプで指定します。

**注記**  
依存関係またはカスタムコネクタを含める場合は、その中にバンドルされていない推移的な依存関係もすべて含める必要があります。