Crie seu serviço gerenciado para o aplicativo Apache Flink Python - Managed Service for Apache Flink
Especifique seus arquivos de código

O Amazon Managed Service para Apache Flink (Amazon MSF) era conhecido anteriormente como Amazon Kinesis Data Analytics for Apache Flink.

As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.

Crie seu serviço gerenciado para o aplicativo Apache Flink Python

Especifique seus arquivos de código

Quando você tiver criado o pacote de código do seu aplicativo, você deve carregá-lo em um bucket do Amazon S3. Em seguida, você cria seu aplicativo usando o console ou a CreateApplicationação.

Ao criar seu aplicativo usando a CreateApplicationação, você especifica os arquivos de código e arquivamentos em seu arquivo zip usando um grupo especial de propriedades do aplicativo chamadokinesis.analytics.flink.run.options. Você pode definir os seguintes tipos de arquivos:

  • python: um arquivo de texto contendo um método principal do Python.

  • jarfile: um arquivo Java JAR contendo funções Java definidas pelo usuário.

  • pyFiles: um arquivo de recursos do Python contendo recursos a serem usados pelo aplicativo.

  • pyArchives: um arquivo zip contendo arquivos de recursos para o aplicativo.

Para obter mais informações sobre os tipos de arquivo de código do Apache Flink Python, consulte Interface de linha de comando na documentação do Apache Flink.

nota

O Managed Service for Apache Flink não suporta os tipos de arquivo pyModule, pyExecutable ou pyRequirements. Todo o código, requisitos e dependências devem estar em seu arquivo zip. Você não pode especificar dependências a serem instaladas usando pip.

O exemplo de trecho json a seguir demonstra como especificar a localização dos arquivos no arquivo zip do seu aplicativo:

"ApplicationConfiguration": {
    "EnvironmentProperties": {
      "PropertyGroups": [
        {
          "PropertyGroupId": "kinesis.analytics.flink.run.options",
          "PropertyMap": {
            "python": "MyApplication/main.py",
            "jarfile": "MyApplication/lib/myJarFile.jar",
            "pyFiles": "MyApplication/lib/myDependentFile.py",
            "pyArchives": "MyApplication/lib/myArchive.zip"
          }
        },