Monitore seu serviço gerenciado para o aplicativo Apache Flink Python - Managed Service for Apache Flink
Registros de consulta com o CloudWatch Insights

Anteriormente, o Amazon Managed Service for Apache Flink era conhecido 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á.

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

Você usa o CloudWatch log do seu aplicativo para monitorar seu serviço gerenciado para o aplicativo Apache Flink Python.

O Managed Service for Apache Flink registra as seguintes mensagens para aplicativos Python:

  • Mensagens escritas no console usando o método do print()aplicativomain.

  • Mensagens enviadas em funções definidas pelo usuário usando o pacote logging. O exemplo de código a seguir demonstra a gravação no log do aplicativo a partir de uma função definida pelo usuário:

    import logging

@udf(input_types=[DataTypes.BIGINT()], result_type=DataTypes.BIGINT())
def doNothingUdf(i):
    logging.info("Got {} in the doNothingUdf".format(str(i)))
    return i

  • Mensagens de erro lançadas pelo aplicativo.

    Se o aplicativo gerar uma exceção na função main, ela aparecerá nos registros do seu aplicativo.

    O exemplo a seguir demonstra uma entrada de registro para uma exceção lançada a partir do código Python:

    2021-03-15 16:21:20.000   --------------------------- Python Process Started --------------------------
2021-03-15 16:21:21.000   Traceback (most recent call last):
2021-03-15 16:21:21.000   "  File ""/tmp/flink-web-6118109b-1cd2-439c-9dcd-218874197fa9/flink-web-upload/4390b233-75cb-4205-a532-441a2de83db3_code/PythonKinesisSink/PythonUdfUndeclared.py"", line 101, in <module>"
2021-03-15 16:21:21.000       main()
2021-03-15 16:21:21.000   "  File ""/tmp/flink-web-6118109b-1cd2-439c-9dcd-218874197fa9/flink-web-upload/4390b233-75cb-4205-a532-441a2de83db3_code/PythonKinesisSink/PythonUdfUndeclared.py"", line 54, in main"
2021-03-15 16:21:21.000   "    table_env.register_function(""doNothingUdf"", doNothingUdf)"
2021-03-15 16:21:21.000   NameError: name 'doNothingUdf' is not defined
2021-03-15 16:21:21.000   --------------------------- Python Process Exited ---------------------------
2021-03-15 16:21:21.000   Run python process failed
2021-03-15 16:21:21.000   Error occurred when trying to start the job
nota

Devido a problemas de desempenho, recomendamos que você use somente mensagens de log personalizadas durante o desenvolvimento do aplicativo.

Registros de consulta com o CloudWatch Insights

A consulta do CloudWatch Insights a seguir pesquisa registros criados pelo ponto de entrada do Python enquanto executa a função principal do seu aplicativo:

fields @timestamp, message
| sort @timestamp asc
| filter logger like /PythonDriver/
| limit 1000