チュートリアル: Studio ノートブックを耐久性のある状態の Apache Flink アプリケーション用 Managed Service としてデプロイする - Managed Service for Apache Flink
前提条件を完了します。AWS Management Consoleを使用して永続的な状態のアプリケーションをデプロイします。AWS CLIを使用して永続的な状態のアプリケーションをデプロイします。

Amazon Managed Service for Apache Flink は、以前は Amazon Kinesis Data Analytics for Apache Flink と呼ばれていました。

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

チュートリアル: Studio ノートブックを耐久性のある状態の Apache Flink アプリケーション用 Managed Service としてデプロイする

以下のチュートリアルでは、Apache Flink アプリケーション用 Managed Service として、 Studio ノートブックを永続的な状態でデプロイする方法を示します。

前提条件を完了します。

Kinesis Data Streams または Amazon を使用してチュートリアル: Managed Service for Apache Flink で Studio ノートブックを作成する、 に従って新しい Studio ノートブックを作成しますMSK。Studio ノートブック ExampleTestDeploy に名前を付けます。

AWS Management Consoleを使用して永続的な状態のアプリケーションをデプロイします。

  1. パッケージ化されたコードを保存する S3 バケットの場所を、コンソールの「アプリケーションコードの場所 - オプショナル」に追加します。これにより、ノートブックから直接アプリケーションをデプロイして実行できるようになります。

  2. アプリケーションの役割に必要な権限を追加して、Amazon S3 バケットの読み取りと書き込みに使用している役割を有効にし、 Apache Flink アプリケーションのホスティングサービスを起動します。

  3. 次のサンプルコードを使用してください。

    %flink.ssql(type=update) 
CREATE TABLE exampleoutput (
  'ticket' VARCHAR,
  'price' DOUBLE
)
WITH (
  'connector' = 'kinesis',
  'stream' = 'ExampleOutputStream',
  'aws.region' = 'us-east-1',
  'scan.stream.initpos' = 'LATEST',
  'format' = 'json'
);

INSERT INTO exampleoutput SELECT ticker, price FROM exampleinputstream

  4. この機能を有効にすると、ノートブック内の各ノートの右上隅に、ノートブックの名前が記載された新しいドロップダウンが表示されます。以下の操作を行うことができます。

    • Studio ノートブックの設定は、 AWS Management Consoleで確認できます。

    • Zeppelin Note を作成して、Amazon S3 にエクスポートします。この時点で、アプリケーションの名前を入力し、「Build および Export」を選択します。エクスポートが完了すると、通知が届きます。

    • 必要に応じて、Amazon S3 で実行可能ファイルの追加テストを表示して実行することができます。

    • 構築が完了すると、永続的な状態と自動スケーリング機能を備えた Kinesis ストリーミングアプリケーションとしてコードをデプロイできるようになります。

    • ドロップダウンを使用して、「Zeppelin Note を Kinesis ストリーミングアプリケーションとしてデプロイ」を選択します。アプリケーション名を確認し、 AWS コンソール 経由でデプロイ を選択します。

    • これにより、Managed Service for Apache Flink アプリケーションを作成するための AWS Management Console ページが表示されます。アプリケーション名、並列処理、コードの場所、デフォルトの Glue DB、 VPC (該当する場合）、IAMロールが事前に入力されていることに注意してください。IAM ロールにソースと送信先に必要なアクセス許可があることを確認します。永続的なアプリケーション状態管理のため、スナップショットはデフォルトで有効になっています。

    • [Create application] を選択します。

    • 「コンフィグ」を選択して任意の設定を変更し、「Run」を選択してストリーミング・アプリケーションを起動することができます。

AWS CLIを使用して永続的な状態のアプリケーションをデプロイします。

を使用してアプリケーションをデプロイするには AWS CLI、ベータ 2 情報で提供されるサービスモデルを使用する AWS CLI ように を更新する必要があります。更新されたサービスモデルの使用方法については、 前提条件を満たす を参照してください。

次のコード例で、新規の Studio ノートブックを作成します。

aws kinesisanalyticsv2 create-application \
     --application-name <app-name> \
     --runtime-environment ZEPPELIN-FLINK-3_0 \
     --application-mode INTERACTIVE \
     --service-execution-role <iam-role>
     --application-configuration '{ 
       "ZeppelinApplicationConfiguration": { 
         "CatalogConfiguration": { 
           "GlueDataCatalogConfiguration": { 
             "DatabaseARN": "arn:aws:glue:us-east-1:<account>:database/<glue-database-name>" 
           } 
         } 
       },
       "FlinkApplicationConfiguration": {
         "ParallelismConfiguration": {
           "ConfigurationType": "CUSTOM",
           "Parallelism": 4,
           "ParallelismPerKPU": 4
         }
       },
       "DeployAsApplicationConfiguration": {
            "S3ContentLocation": { 
               "BucketARN": "arn:aws:s3:::<s3bucket>",
               "BasePath": "/something/"
            }
        },
       "VpcConfigurations": [
         {
           "SecurityGroupIds": [
             "<security-group>"
           ],
           "SubnetIds": [
             "<subnet-1>",
             "<subnet-2>"
           ]
         }
       ]
     }' \
     --region us-east-1

次のコード例で、Studio ノートブックを起動します。

aws kinesisanalyticsv2 start-application \
    --application-name <app-name> \
    --region us-east-1 \
    --no-verify-ssl

次のコードURLは、アプリケーションの Apache Zeppelin ノートブックページの を返します。

aws kinesisanalyticsv2 create-application-presigned-url \
    --application-name <app-name> \
    --url-type ZEPPELIN_UI_URL \

    --region us-east-1 \
    --no-verify-ssl