Código de ejemplo de la API de Managed Service for Apache Flink

Este tema contiene ejemplos de bloques de solicitud de acciones de Managed Service para Apache Flink.

Para usar JSON como entrada para una acción con AWS Command Line Interface (AWS CLI), guarda la solicitud en un archivo JSON. A continuación, pase el nombre del archivo a la acción mediante el parámetro --cli-input-json.

En el siguiente ejemplo se muestra cómo utilizar un archivo JSON con una acción.


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

Para obtener más información sobre el uso de JSON con AWS CLI, consulte Generar el esqueleto de la CLI y los parámetros JSON de entrada de CLI en la Guía del AWS Command Line Interface usuario.

AddApplicationCloudWatchLoggingOption

El siguiente ejemplo de código de solicitud para la AddApplicationCloudWatchLoggingOptionacción añade una opción de CloudWatch registro de Amazon a una aplicación de 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

El siguiente ejemplo de código de solicitud para la AddApplicationInputacción añade una entrada de aplicación a una aplicación de 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

El siguiente ejemplo de código de solicitud para la AddApplicationInputProcessingConfigurationacción agrega una configuración de procesamiento de entradas de una aplicación a una aplicación de 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

El siguiente ejemplo de código de solicitud para la AddApplicationOutputacción añade un flujo de datos de Kinesis como salida de una aplicación a una aplicación de 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

El siguiente ejemplo de código de solicitud para la AddApplicationReferenceDataSourceacción añade una fuente de datos de referencia de una aplicación CSV a una aplicación de 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:::MyS3Bucket",
         "FileKey": "TickerReference.csv"
      },
      "TableName": "string"
   }
}

AddApplicationVpcConfiguration

El siguiente ejemplo de código de solicitud para la AddApplicationVpcConfigurationacción agrega una configuración de VPC a una aplicación existente:


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

CreateApplication

El siguiente ejemplo de código de solicitud para la CreateApplicationacción crea un servicio gestionado para la aplicación 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:::mybucket",
          "FileKey":"myflink.jar",
          "ObjectVersion":"AbCdEfGhIjKlMnOpQrStUvWxYz12345"
        }
      },
      "CodeContentType":"ZIPFILE"
    },
      "FlinkApplicationConfiguration":{
      "ParallelismConfiguration":{
        "ConfigurationType":"CUSTOM",
        "Parallelism":2,
        "ParallelismPerKPU":1,
        "AutoScalingEnabled":true
      }
    }
  }
}

CreateApplicationSnapshot

El siguiente ejemplo de código de solicitud para la CreateApplicationSnapshotacción crea una instantánea del estado de la aplicación:


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

DeleteApplication

El siguiente ejemplo de código de solicitud para la DeleteApplicationacción elimina una aplicación de Managed Service for Apache Flink:


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

DeleteApplicationCloudWatchLoggingOption

El siguiente ejemplo de código de solicitud para la DeleteApplicationCloudWatchLoggingOptionacción elimina una opción de CloudWatch registro de Amazon de una aplicación de Managed Service for Apache Flink:


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

DeleteApplicationInputProcessingConfiguration

El siguiente ejemplo de código de solicitud para la DeleteApplicationInputProcessingConfigurationacción elimina una configuración de procesamiento de entradas de una aplicación de Managed Service for Apache Flink:


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

DeleteApplicationOutput

El siguiente ejemplo de código de solicitud para la DeleteApplicationOutputacción elimina el resultado de una aplicación de Managed Service for Apache Flink:


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

DeleteApplicationReferenceDataSource

El siguiente ejemplo de código de solicitud para la DeleteApplicationReferenceDataSourceacción elimina una fuente de datos de referencia de una aplicación de Managed Service for Apache Flink:


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

DeleteApplicationSnapshot

El siguiente ejemplo de código de solicitud para la DeleteApplicationSnapshotacción elimina una instantánea del estado de la aplicación:


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

DeleteApplicationVpcConfiguration

El siguiente ejemplo de código de solicitud para la DeleteApplicationVpcConfigurationacción elimina una configuración de VPC existente de una aplicación:


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

DescribeApplication

El siguiente ejemplo de código de solicitud para la DescribeApplicationacción devuelve detalles sobre una aplicación de Managed Service for Apache Flink:


{"ApplicationName": "MyApplication"}

DescribeApplicationSnapshot

El siguiente ejemplo de código de solicitud para la DescribeApplicationSnapshotacción devuelve detalles sobre una instantánea del estado de la aplicación:


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

DiscoverInputSchema

El siguiente ejemplo de código de solicitud para la DiscoverInputSchemaacción genera un esquema a partir de una fuente 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"
}

El siguiente ejemplo de código de solicitud para la DiscoverInputSchemaacción genera un esquema a partir de una fuente de referencia:


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

ListApplications

El siguiente ejemplo de código de solicitud para la ListApplicationsacción devuelve una lista de las aplicaciones de Managed Service for Apache Flink de su cuenta:


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

ListApplicationSnapshots

El siguiente ejemplo de código de solicitud para la ListApplicationSnapshotsacción devuelve una lista de instantáneas del estado de la aplicación:


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

StartApplication

El siguiente ejemplo de código de solicitud para la StartApplicationacción inicia una aplicación de Managed Service for Apache Flink y carga el estado de la aplicación a partir de la última instantánea (si la hubiera):


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

StopApplication

El siguiente ejemplo de código de solicitud para la StopApplication acción API_ detiene una aplicación de Managed Service for Apache Flink:


{"ApplicationName": "MyApplication"}

UpdateApplication

El siguiente ejemplo de código de solicitud para la UpdateApplicationacción actualiza una aplicación de Managed Service for Apache Flink para cambiar la ubicación del código de la aplicación:


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

Aviso JavaScript está desactivado o no está disponible en su navegador.

Para utilizar la documentación de AWS, debe estar habilitado JavaScript. Para obtener más información, consulte las páginas de ayuda de su navegador.

Convenciones del documento

Historial de documentos

Referencia de la API