APIExemple de code de service géré pour Apache Flink

Cette rubrique contient un exemple de blocs de requêtes pour les actions du service géré pour Apache Flink.

Pour l'utiliser JSON comme entrée pour une action avec le AWS Command Line Interface (AWS CLI), enregistrez la demande dans un JSON fichier. Transmettez ensuite le nom du fichier à l’action à l’aide du paramètre --cli-input-json.

L'exemple suivant montre comment utiliser un JSON fichier avec une action.


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

Pour plus d'informations sur l'utilisation JSON du AWS CLI, voir Generate CLI Skeleton and CLI Input JSON Parameters dans le guide de AWS Command Line Interface l'utilisateur.

AddApplicationCloudWatchLoggingOption

L'exemple de code de demande suivant pour l'AddApplicationCloudWatchLoggingOptionaction ajoute une option de CloudWatch journalisation Amazon à une application Managed Service for 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

L'exemple de code de demande suivant pour l'AddApplicationInputaction ajoute une entrée d'application à une application Managed Service for 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

L'exemple de code de demande suivant pour l'AddApplicationInputProcessingConfigurationaction ajoute une configuration de traitement des entrées d'application à une application Managed Service for Apache Flink :


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

AddApplicationOutput

L'exemple de code de demande suivant pour l'AddApplicationOutputaction ajoute un flux de données Kinesis en tant que sortie d'application à une application Managed Service for 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

L'exemple de code de demande suivant pour l'AddApplicationReferenceDataSourceaction ajoute une source de données de référence d'CSVapplication à une application Managed Service for 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

L'exemple de code de demande suivant pour l'AddApplicationVpcConfigurationaction ajoute une VPC configuration à une application existante :


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

CreateApplication

L'exemple de code de demande suivant pour l'CreateApplicationaction crée un service géré pour l'application 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

L'exemple de code de demande suivant pour l'CreateApplicationSnapshotaction crée un instantané de l'état de l'application :


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

DeleteApplication

L'exemple de code de demande suivant pour l'DeleteApplicationaction supprime une application Managed Service for Apache Flink :


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

DeleteApplicationCloudWatchLoggingOption

L'exemple de code de demande suivant pour l'DeleteApplicationCloudWatchLoggingOptionaction supprime une option de CloudWatch journalisation Amazon d'une application Managed Service for Apache Flink :


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

DeleteApplicationInputProcessingConfiguration

L'exemple de code de demande suivant pour l'DeleteApplicationInputProcessingConfigurationaction supprime une configuration de traitement des entrées d'une application Managed Service for Apache Flink :


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

DeleteApplicationOutput

L'exemple de code de demande suivant pour l'DeleteApplicationOutputaction supprime une sortie d'application d'une application Managed Service for Apache Flink :


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

DeleteApplicationReferenceDataSource

L'exemple de code de demande suivant pour l'DeleteApplicationReferenceDataSourceaction supprime une source de données de référence d'application d'une application Managed Service for Apache Flink :


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

DeleteApplicationSnapshot

L'exemple de code de demande suivant pour l'DeleteApplicationSnapshotaction supprime un instantané de l'état de l'application :


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

DeleteApplicationVpcConfiguration

L'exemple de code de demande suivant pour l'DeleteApplicationVpcConfigurationaction supprime une VPC configuration existante d'une application :


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

DescribeApplication

L'exemple de code de demande suivant pour l'DescribeApplicationaction renvoie des informations sur une application Managed Service for Apache Flink :


{"ApplicationName": "MyApplication"}

DescribeApplicationSnapshot

L'exemple de code de demande suivant pour l'DescribeApplicationSnapshotaction renvoie des détails sur un instantané de l'état de l'application :


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

DiscoverInputSchema

L'exemple de code de demande suivant pour l'DiscoverInputSchemaaction génère un schéma à partir d'une source de 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"
}

L'exemple de code de demande suivant pour l'DiscoverInputSchemaaction génère un schéma à partir d'une source de référence :


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

ListApplications

L'exemple de code de demande suivant pour l'ListApplicationsaction renvoie une liste des applications Managed Service for Apache Flink de votre compte :


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

ListApplicationSnapshots

L'exemple de code de demande suivant pour l'ListApplicationSnapshotsaction renvoie une liste d'instantanés de l'état de l'application :


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

StartApplication

L'exemple de code de demande suivant pour l'StartApplicationaction démarre une application Managed Service for Apache Flink et charge l'état de l'application à partir du dernier instantané (le cas échéant) :


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

StopApplication

L'exemple de code de demande suivant pour l'API_StopApplicationaction arrête une application Managed Service for Apache Flink :


{"ApplicationName": "MyApplication"}

UpdateApplication

L'exemple de code de demande suivant pour l'UpdateApplicationaction met à jour une application Managed Service for Apache Flink afin de modifier l'emplacement du code de l'application :


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

Avertissement JavaScript est désactivé ou n'est pas disponible dans votre navigateur.

Pour que vous puissiez utiliser la documentation AWS, Javascript doit être activé. Vous trouverez des instructions sur les pages d'aide de votre navigateur.

Conventions de rédaction

Historique de la documentation

Référence d’API