本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。
# 使用連接器透過 DataStream API 在 Managed Service for Apache Flink 中移動資料
在 Amazon Managed Service for Apache Flink DataStream API 中，*連接器*是可將資料移入和移出 Managed Service for Apache Flink 應用程式的軟體元件。連接器是靈活的整合，可讓您從檔案和目錄讀取。連接器包含用於與 Amazon 服務和第三方系統互動的完整模組。
連接器包含下列類型：
+ [新增串流資料來源](how-sources.md)：從 Kinesis 資料串流、檔案或其他資料來源向應用程式提供資料。
+ [使用接收器寫入資料](how-sinks.md)：從您的應用程式將資料傳送至 Kinesis 資料串流、Firehose 串流或其他資料目的地。
+ [使用非同步 I/O](how-async.md)：提供對資料來源 (例如資料庫) 的非同步存取，以富集串流事件。
## 可用的連接器
Apache Flink 架構包含用於存取各種來源之資料的連接器。如需 Apache Flink 架構中可用連接器的相關資訊，請參閱 [Apache Flink 文件](https://nightlies.apache.org/flink/flink-docs-release-1.15/)中的[連接器](https://nightlies.apache.org/flink/flink-docs-release-1.15/dev/connectors/)。
**警告**
如果您的應用程式在 Flink 1.6、1.8、1.11 或 1.13 上執行，並且想要在中東 （阿拉伯聯合大公國）、亞太區域 （海德拉巴）、以色列 （特拉維夫）、歐洲 （蘇黎世）、中東 （阿拉伯聯合大公國）、亞太區域 （墨爾本） 或亞太區域 （雅加達） 區域執行，您可能需要使用更新的連接器重建應用程式封存，或升級至 Flink 1.18。
Apache Flink 連接器存放在自己的開放原始碼儲存庫中。如果您要升級至 1.18 版或更新版本，則必須更新您的相依性。若要存取 Apache Flink AWS 連接器的儲存庫，請參閱 [flink-connector-aws](https://github.com/apache/flink-connector-aws)。
之前的 Kinesis 來源`org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer`已停止，未來可能會隨著 Flink 版本而移除。請改用 [Kinesis 來源](https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/connectors/datastream/kinesis/#kinesis-streams-source)。
`FlinkKinesisConsumer` 和 之間沒有狀態相容性`KinesisStreamsSource`。如需詳細資訊，請參閱 Apache Flink 文件中的[將現有任務遷移至新的 Kinesis 串流來源](https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/connectors/datastream/kinesis/#migrating-existing-jobs-to-new-kinesis-streams-source-from-kinesis-consumer)。
以下是建議的準則：
**連接器升級**
| Flink 版本 | 使用的連接器 | Resolution |
| --- | --- | --- |
| 1.19、1.20 | Kinesis 來源 | 升級至 Managed Service for Apache Flink 1.19 和 1.20 版時，請確定您使用的是最新的 Kinesis Data Streams 來源連接器。這必須是任何 5.0.0 版或更新版本。如需詳細資訊，請參閱 [Amazon Kinesis Data Streams Connector](https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/datastream/kinesis/)。 |
| 1.19、1.20 | Kinesis 接收器 | 升級至 Managed Service for Apache Flink 1.19 和 1.20 版時，請確定您使用的是最新的 Kinesis Data Streams 接收器連接器。這必須是任何 5.0.0 版或更新版本。如需詳細資訊，請參閱 [Kinesis Streams Sink](https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/connectors/datastream/kinesis/#kinesis-streams-sink)。 |
| 1.19、1.20 | DynamoDB 串流來源 | 升級至 Managed Service for Apache Flink 1.19 和 1.20 版時，請確定您使用的是最新的 DynamoDB Streams 來源連接器。這必須是任何 5.0.0 版或更新版本。如需詳細資訊，請參閱 [Amazon DynamoDB 連接器](https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/datastream/dynamodb/)。 |
| 1.19、1.20 | DynamoDB 接收器 | 升級至 Managed Service for Apache Flink 1.19 和 1.20 版時，請確定您使用的是最新的 DynamoDB 接收器連接器。這必須是任何 5.0.0 版或更新版本。如需詳細資訊，請參閱 [Amazon DynamoDB 連接器](https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/datastream/dynamodb/)。 |
| 1.19、1.20 | Amazon SQS 接收器 | 升級至 Managed Service for Apache Flink 1.19 和 1.20 版時，請確定您使用的是最新的 Amazon SQS 接收器連接器。這必須是任何 5.0.0 版或更新版本。如需詳細資訊，請參閱 [Amazon SQS Sink](https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/datastream/sqs/)。 |
| 1.19、1.20 | Amazon Managed Service for Prometheus Sink | 升級至 Managed Service for Apache Flink 1.19 和 1.20 版時，請確定您使用的是最新的 Amazon Managed Service for Prometheus 接收器連接器。這必須是任何 1.0.0 版或更新版本。如需詳細資訊，請參閱 [Prometheus Sink](https://nightlies.apache.org/flink/flink-docs-stable/docs/connectors/datastream/prometheus/)。 |