Amazon Managed Service für Apache Flink war zuvor als Amazon Kinesis Data Analytics für Apache Flink bekannt.

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

APIBeispielcode für Managed Service für Apache Flink

Dieses Thema enthält Beispielanforderungsblöcke für Managed Service für Apache Flink-Aktionen.

Um die Anfrage JSON als Eingabe für eine Aktion mit dem AWS Command Line Interface (AWS CLI) zu verwenden, speichern Sie die Anfrage in einer JSON Datei. Übergeben Sie dann den Dateinamen mithilfe des Parameters --cli-input-json an die Aktion.

Das folgende Beispiel zeigt, wie eine JSON Datei mit einer Aktion verwendet wird.

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

Weitere Informationen zur Verwendung JSON mit finden Sie unter Generate CLI Skeleton und CLI Input JSON Parameters im AWS Command Line Interface Benutzerhandbuch. AWS CLI

AddApplicationCloudWatchLoggingOption

Der folgende Beispiel-Anforderungscode für die AddApplicationCloudWatchLoggingOptionAktion fügt einer Managed Service for Apache Flink-Anwendung eine CloudWatch Amazon-Protokollierungsoption hinzu:

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

AddApplicationInput

Der folgende Beispiel-Anforderungscode für die AddApplicationInputAktion fügt einer Managed Service for Apache Flink-Anwendung eine Anwendungseingabe hinzu:

{
   "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

Der folgende Beispiel-Anforderungscode für die AddApplicationInputProcessingConfigurationAktion fügt einer Managed Service for Apache Flink-Anwendung eine Konfiguration zur Verarbeitung von Anwendungseingaben hinzu:

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

AddApplicationOutput

Der folgende Beispiel-Anforderungscode für die AddApplicationOutputAktion fügt einen Kinesis-Datenstream als Anwendungsausgabe zu einer Managed Service for Apache Flink-Anwendung hinzu:

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

AddApplicationReferenceDataSource

Der folgende Beispiel-Anforderungscode für die AddApplicationReferenceDataSourceAktion fügt einer Managed Service for Apache CSV Flink-Anwendung eine Anwendungsreferenzdatenquelle hinzu:

{
   "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

Der folgende Beispiel-Anforderungscode für die AddApplicationVpcConfigurationAktion fügt einer vorhandenen Anwendung eine VPC Konfiguration hinzu:

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

CreateApplication

Der folgende Beispiel-Anforderungscode für die CreateApplicationAktion erstellt eine Managed Service for Apache Flink-Anwendung:

{
  "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

Der folgende Beispiel-Anforderungscode für die CreateApplicationSnapshotAktion erstellt eine Momentaufnahme des Anwendungsstatus:

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

DeleteApplication

Der folgende Beispiel-Anforderungscode für die DeleteApplicationAktion löscht eine Managed Service for Apache Flink-Anwendung:

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

DeleteApplicationCloudWatchLoggingOption

Der folgende Beispiel-Anforderungscode für die DeleteApplicationCloudWatchLoggingOptionAktion löscht eine CloudWatch Amazon-Protokollierungsoption aus einer Managed Service for Apache Flink-Anwendung:

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

DeleteApplicationInputProcessingConfiguration

Der folgende Beispiel-Anforderungscode für die DeleteApplicationInputProcessingConfigurationAktion entfernt eine Konfiguration zur Eingabeverarbeitung aus einer Managed Service for Apache Flink-Anwendung:

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

DeleteApplicationOutput

Der folgende Beispiel-Anforderungscode für die DeleteApplicationOutputAktion entfernt eine Anwendungsausgabe aus einer Managed Service for Apache Flink-Anwendung:

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

DeleteApplicationReferenceDataSource

Der folgende Beispiel-Anforderungscode für die DeleteApplicationReferenceDataSourceAktion entfernt eine Anwendungsreferenzdatenquelle aus einer Managed Service for Apache Flink-Anwendung:

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

DeleteApplicationSnapshot

Der folgende Beispiel-Anforderungscode für die DeleteApplicationSnapshotAktion löscht einen Snapshot des Anwendungsstatus:

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

DeleteApplicationVpcConfiguration

Der folgende Beispiel-Anforderungscode für die DeleteApplicationVpcConfigurationAktion entfernt eine bestehende VPC Konfiguration aus einer Anwendung:

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

DescribeApplication

Der folgende Beispiel-Anforderungscode für die DescribeApplicationAktion gibt Details zu einer Managed Service for Apache Flink-Anwendung zurück:

{"ApplicationName": "MyApplication"}

DescribeApplicationSnapshot

Der folgende Beispiel-Anforderungscode für die DescribeApplicationSnapshotAktion gibt Details über einen Snapshot des Anwendungsstatus zurück:

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

DiscoverInputSchema

Der folgende Beispiel-Anforderungscode für die DiscoverInputSchemaAktion generiert ein Schema aus einer Streaming-Quelle:

{
   "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"
}

Der folgende Beispiel-Anforderungscode für die DiscoverInputSchemaAktion generiert ein Schema aus einer Referenzquelle:

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

ListApplications

Der folgende Beispiel-Anforderungscode für die ListApplicationsAktion gibt eine Liste der Managed Service for Apache Flink-Anwendungen in Ihrem Konto zurück:

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

ListApplicationSnapshots

Der folgende Beispiel-Anforderungscode für die ListApplicationSnapshotsAktion gibt eine Liste von Snapshots des Anwendungsstatus zurück:

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

StartApplication

Der folgende Beispiel-Anforderungscode für die StartApplicationAktion startet eine Managed Service for Apache Flink-Anwendung und lädt den Anwendungsstatus aus dem letzten Snapshot (falls vorhanden):

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

StopApplication

Der folgende Beispiel-Anforderungscode für die API_StopApplicationAktion beendet eine Managed Service for Apache Flink-Anwendung:

{"ApplicationName": "MyApplication"}

UpdateApplication

Der folgende Beispiel-Anforderungscode für die UpdateApplicationAktion aktualisiert eine Managed Service for Apache Flink-Anwendung, um den Speicherort des Anwendungscodes zu ändern:

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