Amazon Managed Service untuk Apache Flink sebelumnya dikenal sebagai Amazon Kinesis Data Analytics untuk Apache Flink.

Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Layanan Terkelola untuk kode contoh Apache Flink API

Topik ini berisi contoh blok permintaan untuk Layanan Terkelola untuk tindakan Apache Flink.

Untuk digunakan JSON sebagai input untuk tindakan dengan AWS Command Line Interface (AWS CLI), simpan permintaan dalam JSON file. Selanjutnya teruskan nama file ke dalam tindakan menggunakan parameter --cli-input-json.

Contoh berikut menunjukkan bagaimana menggunakan JSON file dengan tindakan.

$ aws kinesisanalyticsv2 start-application --cli-input-json file://start.json

Untuk informasi selengkapnya tentang penggunaan JSON dengan AWS CLI, lihat Menghasilkan JSON Parameter CLI Kerangka dan CLI Input di Panduan AWS Command Line Interface Pengguna.

AddApplicationCloudWatchLoggingOption

Contoh kode permintaan berikut untuk AddApplicationCloudWatchLoggingOptiontindakan menambahkan opsi CloudWatch pencatatan Amazon ke Layanan Terkelola untuk aplikasi Apache Flink:

{
    "ApplicationName": "MyApplication",
    "CloudWatchLoggingOption": {
        "LogStreamARN": "arn:aws:logs:us-east-1:123456789123:log-group:my-log-group:log-stream:My-LogStream"
    },
    "CurrentApplicationVersionId": 2
}

AddApplicationInput

Contoh kode permintaan berikut untuk AddApplicationInputtindakan menambahkan input aplikasi ke Layanan Terkelola untuk aplikasi Apache Flink:

{
   "ApplicationName": "MyApplication",
   "CurrentApplicationVersionId": 2,
   "Input": { 
      "InputParallelism": { 
         "Count": 2
      },
      "InputSchema": { 
         "RecordColumns": [ 
            { 
               "Mapping": "$.TICKER",
               "Name": "TICKER_SYMBOL",
               "SqlType": "VARCHAR(50)"
            },
            {
                "SqlType": "REAL",
                "Name": "PRICE",
                "Mapping": "$.PRICE"
            }
         ],
         "RecordEncoding": "UTF-8",
         "RecordFormat": { 
            "MappingParameters": { 
               "JSONMappingParameters": { 
                  "RecordRowPath": "$"
               }
            },
            "RecordFormatType": "JSON"
         }
      },
      "KinesisStreamsInput": { 
         "ResourceARN": "arn:aws:kinesis:us-east-1:012345678901:stream/ExampleInputStream"
      }
   }
}

AddApplicationInputProcessingConfiguration

Contoh kode permintaan berikut untuk AddApplicationInputProcessingConfigurationtindakan menambahkan konfigurasi pemrosesan input aplikasi ke Layanan Terkelola untuk aplikasi Apache Flink:

{
   "ApplicationName": "MyApplication",
   "CurrentApplicationVersionId": 2,
   "InputId": "2.1",
   "InputProcessingConfiguration": { 
      "InputLambdaProcessor": { 
         "ResourceARN": "arn:aws:lambda:us-east-1:012345678901:function:MyLambdaFunction"
      }
   }
}

AddApplicationOutput

Contoh kode permintaan berikut untuk AddApplicationOutputtindakan menambahkan aliran data Kinesis sebagai output aplikasi ke Layanan Terkelola untuk aplikasi Apache Flink:

{
   "ApplicationName": "MyApplication",
   "CurrentApplicationVersionId": 2,
   "Output": { 
      "DestinationSchema": { 
         "RecordFormatType": "JSON"
      },
      "KinesisStreamsOutput": { 
         "ResourceARN": "arn:aws:kinesis:us-east-1:012345678901:stream/ExampleOutputStream"
      },
      "Name": "DESTINATION_SQL_STREAM"
   }
}

AddApplicationReferenceDataSource

Contoh kode permintaan berikut untuk AddApplicationReferenceDataSourcetindakan menambahkan sumber data referensi CSV aplikasi ke Layanan Terkelola untuk aplikasi Apache Flink:

{
   "ApplicationName": "MyApplication",
   "CurrentApplicationVersionId": 5,
   "ReferenceDataSource": { 
      "ReferenceSchema": { 
         "RecordColumns": [ 
            { 
               "Mapping": "$.TICKER",
               "Name": "TICKER",
               "SqlType": "VARCHAR(4)"
            },
            { 
               "Mapping": "$.COMPANYNAME",
               "Name": "COMPANY_NAME",
               "SqlType": "VARCHAR(40)"
            },
         ],
         "RecordEncoding": "UTF-8",
         "RecordFormat": { 
            "MappingParameters": { 
               "CSVMappingParameters": { 
                  "RecordColumnDelimiter": " ",
                  "RecordRowDelimiter": "\r\n"
               }
            },
            "RecordFormatType": "CSV"
         }
      },
      "S3ReferenceDataSource": { 
         "BucketARN": "arn:aws:s3:::amzn-s3-demo-bucket",
         "FileKey": "TickerReference.csv"
      },
      "TableName": "string"
   }
}

AddApplicationVpcConfiguration

Contoh kode permintaan berikut untuk AddApplicationVpcConfigurationtindakan menambahkan VPC konfigurasi ke aplikasi yang ada:

{
   "ApplicationName": "MyApplication",
   "CurrentApplicationVersionId": 9,
   "VpcConfiguration": { 
      "SecurityGroupIds": [ "sg-0123456789abcdef0" ],
      "SubnetIds": [ "subnet-0123456789abcdef0" ]
   }
}
            

CreateApplication

Contoh kode permintaan berikut untuk CreateApplicationtindakan membuat Layanan Terkelola untuk aplikasi Apache Flink:

{
  "ApplicationName":"MyApplication",
  "ApplicationDescription":"My-Application-Description",
  "RuntimeEnvironment":"FLINK-1_15",
  "ServiceExecutionRole":"arn:aws:iam::123456789123:role/myrole",
  "CloudWatchLoggingOptions":[
    {
      "LogStreamARN":"arn:aws:logs:us-east-1:123456789123:log-group:my-log-group:log-stream:My-LogStream"
    }
  ],
  "ApplicationConfiguration": {
    "EnvironmentProperties":
      {"PropertyGroups": 
        [
          {"PropertyGroupId": "ConsumerConfigProperties",
            "PropertyMap": 
              {"aws.region": "us-east-1",
              "flink.stream.initpos": "LATEST"}
          },
          {"PropertyGroupId": "ProducerConfigProperties",
            "PropertyMap": 
              {"aws.region": "us-east-1"}
          },
        ]
      },
    "ApplicationCodeConfiguration":{
      "CodeContent":{
        "S3ContentLocation":{
          "BucketARN":"arn:aws:s3:::amzn-s3-demo-bucket",
          "FileKey":"myflink.jar",
          "ObjectVersion":"AbCdEfGhIjKlMnOpQrStUvWxYz12345"
        }
      },
      "CodeContentType":"ZIPFILE"
    },
      "FlinkApplicationConfiguration":{
      "ParallelismConfiguration":{
        "ConfigurationType":"CUSTOM",
        "Parallelism":2,
        "ParallelismPerKPU":1,
        "AutoScalingEnabled":true
      }
    }
  }
}

CreateApplicationSnapshot

Contoh kode permintaan berikut untuk CreateApplicationSnapshottindakan membuat snapshot dari status aplikasi:

{
   "ApplicationName": "MyApplication",
   "SnapshotName": "MySnapshot"
}

DeleteApplication

Contoh kode permintaan berikut untuk DeleteApplicationtindakan menghapus Layanan Terkelola untuk aplikasi Apache Flink:

{"ApplicationName": "MyApplication",
"CreateTimestamp": 12345678912}

DeleteApplicationCloudWatchLoggingOption

Contoh kode permintaan berikut untuk DeleteApplicationCloudWatchLoggingOptiontindakan menghapus opsi CloudWatch pencatatan Amazon dari Layanan Terkelola untuk aplikasi Apache Flink:

{
    "ApplicationName": "MyApplication",
    "CloudWatchLoggingOptionId": "3.1"
    "CurrentApplicationVersionId": 3
}

DeleteApplicationInputProcessingConfiguration

Contoh kode permintaan berikut untuk DeleteApplicationInputProcessingConfigurationtindakan menghapus konfigurasi pemrosesan input dari Layanan Terkelola untuk aplikasi Apache Flink:

{
   "ApplicationName": "MyApplication",
   "CurrentApplicationVersionId": 4,
   "InputId": "2.1"
}

DeleteApplicationOutput

Contoh kode permintaan berikut untuk DeleteApplicationOutputtindakan menghapus output aplikasi dari Layanan Terkelola untuk aplikasi Apache Flink:

{
   "ApplicationName": "MyApplication",
   "CurrentApplicationVersionId": 4,
   "OutputId": "4.1"
}

DeleteApplicationReferenceDataSource

Contoh kode permintaan berikut untuk DeleteApplicationReferenceDataSourcetindakan menghapus sumber data referensi aplikasi dari Layanan Terkelola untuk aplikasi Apache Flink:

{
   "ApplicationName": "MyApplication",
   "CurrentApplicationVersionId": 5,
   "ReferenceId": "5.1"
}

DeleteApplicationSnapshot

Contoh kode permintaan berikut untuk DeleteApplicationSnapshottindakan menghapus snapshot dari status aplikasi:

{
   "ApplicationName": "MyApplication",
   "SnapshotCreationTimestamp": 12345678912,
   "SnapshotName": "MySnapshot"
}

DeleteApplicationVpcConfiguration

Contoh kode permintaan berikut untuk DeleteApplicationVpcConfigurationtindakan menghapus VPC konfigurasi yang ada dari aplikasi:

{
   "ApplicationName": "MyApplication",
   "CurrentApplicationVersionId": 9,
   "VpcConfigurationId": "1.1"
}
            

DescribeApplication

Contoh kode permintaan berikut untuk DescribeApplicationtindakan mengembalikan rincian tentang Layanan Terkelola untuk aplikasi Apache Flink:

{"ApplicationName": "MyApplication"}

DescribeApplicationSnapshot

Contoh kode permintaan berikut untuk DescribeApplicationSnapshottindakan mengembalikan rincian tentang snapshot dari status aplikasi:

{
   "ApplicationName": "MyApplication",
   "SnapshotName": "MySnapshot"
}

DiscoverInputSchema

Contoh kode permintaan berikut untuk DiscoverInputSchematindakan menghasilkan skema dari sumber streaming:

{
   "InputProcessingConfiguration": { 
      "InputLambdaProcessor": { 
         "ResourceARN": "arn:aws:lambda:us-east-1:012345678901:function:MyLambdaFunction"
      }
   },
   "InputStartingPositionConfiguration": { 
      "InputStartingPosition": "NOW"
   },
   "ResourceARN": "arn:aws:kinesis:us-east-1:012345678901:stream/ExampleInputStream",
   "S3Configuration": { 
      "BucketARN": "string",
      "FileKey": "string"
   },
   "ServiceExecutionRole": "string"
}

Contoh kode permintaan berikut untuk DiscoverInputSchematindakan menghasilkan skema dari sumber referensi:

{
   "S3Configuration": { 
      "BucketARN": "arn:aws:s3:::amzn-s3-demo-bucket",
      "FileKey": "TickerReference.csv"
   },
   "ServiceExecutionRole": "arn:aws:iam::123456789123:role/myrole"
}

ListApplications

Contoh kode permintaan berikut untuk ListApplicationstindakan mengembalikan daftar Layanan Terkelola untuk aplikasi Apache Flink di akun Anda:

{
   "ExclusiveStartApplicationName": "MyApplication",
   "Limit": 50
}

ListApplicationSnapshots

Contoh kode permintaan berikut untuk ListApplicationSnapshotstindakan mengembalikan daftar snapshot dari status aplikasi:

{"ApplicationName": "MyApplication",
   "Limit": 50,
   "NextToken": "aBcDeFgHiJkLmNoPqRsTuVwXyZ0123"
}

StartApplication

Contoh kode permintaan berikut untuk StartApplicationtindakan memulai Layanan Terkelola untuk aplikasi Apache Flink, dan memuat status aplikasi dari snapshot terbaru (jika ada):

{
    "ApplicationName": "MyApplication",
    "RunConfiguration": {
        "ApplicationRestoreConfiguration": { 
         "ApplicationRestoreType": "RESTORE_FROM_LATEST_SNAPSHOT"
         }
    }
}

StopApplication

Contoh kode permintaan berikut untuk API_StopApplicationtindakan menghentikan Layanan Terkelola untuk aplikasi Apache Flink:

{"ApplicationName": "MyApplication"}

UpdateApplication

Contoh kode permintaan berikut untuk UpdateApplicationtindakan memperbarui Layanan Terkelola untuk aplikasi Apache Flink untuk mengubah lokasi kode aplikasi:

{"ApplicationName": "MyApplication",
"CurrentApplicationVersionId": 1,
"ApplicationConfigurationUpdate": { 
      "ApplicationCodeConfigurationUpdate": { 
         "CodeContentTypeUpdate": "ZIPFILE",
         "CodeContentUpdate": { 
            "S3ContentLocationUpdate": { 
               "BucketARNUpdate": "arn:aws:s3:::new_amzn-s3-demo-bucket",
               "FileKeyUpdate": "my_new_code.zip",
               "ObjectVersionUpdate": "2"
         }
      }
   }
}