Amazon Managed Service para Apache Flink Amazon (Amazon MSF) se denominaba anteriormente Amazon Kinesis Data Analytics para Apache Flink.
Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.
Realización de análisis interactivo de los datos del flujo
Utiliza un portátil sin servidor con tecnología Apache Zeppelin para interactuar con sus datos de streaming. Su cuaderno puede tener varias notas y cada nota puede tener uno o más párrafos en los que puede escribir el código.
El siguiente ejemplo de consulta SQL muestra cómo recuperar datos de un origen de datos:
%flink.ssql(type=update) select * from stock;
Para ver más ejemplos de consultas SQL de Flink Streaming, consulte Ejemplos y tutoriales para cuadernos de Studio en Managed Service para Apache Flink a continuación y Queries
Se puede utilizar las consultas SQL de Flink del cuaderno de Studio para consultar los datos de streaming. También puedes usar Python (API de tabla) y Scala (tabla y flujo de datos APIs) para escribir programas que consulten tus datos de streaming de forma interactiva. Se puede ver los resultados de sus consultas o programas, actualizarlos en cuestión de segundos y volver a ejecutarlos para ver los resultados actualizados.
Intérpretes de Flink
Usted especifica el idioma que utiliza Managed Service para Apache Flink para ejecutar su aplicación mediante un intérprete. Se puede usar los siguientes intérpretes con Managed Service para Apache Flink:
| Name | Clase | Description (Descripción) |
|---|---|---|
| %flink | FlinkInterpreter | Crea ExecutionEnvironment/StreamExecutionEnvironment/BatchTableEnvironment/StreamTableEnvironmenty proporciona un entorno de Scala |
| %flink.pyflink | PyFlinkInterpreter | Proporciona un entorno de python |
| %flink.ipyflink | IPyFlinkInterpreter | Proporciona un entorno ipython |
| %flink.ssql | FlinkStreamSqlInterpreter | Proporciona un entorno de flujo sql |
| %flink.bsql | FlinkBatchSqlInterpreter | Proporciona un entorno sql por lotes |
Para obtener más información sobre los intérpretes de Flink, consulte Flink interpreter for Apache Zeppelin
Si se utiliza %flink.pyflink o %flink.ipyflink como intérpretes, necesitará usar ZeppelinContext para visualizar los resultados en el cuaderno.
Para ver ejemplos más PyFlink específicos, consulte Consulte sus flujos de datos de forma interactiva mediante Managed Service para Apache Flink Studio y Python
Variables de entorno de la tabla de Apache Flink
Apache Zeppelin proporciona acceso a los recursos del entorno de la tabla mediante variables de entorno.
Se accede a los recursos del entorno de tablas de Scala con las siguientes variables:
| Variable | Recurso |
|---|---|
senv | StreamExecutionEnvironment |
stenv | StreamTableEnvironment for blink planner |
Se puede acceder a los recursos del entorno de tablas de Python con las siguientes variables:
| Variable | Recurso |
|---|---|
s_env | StreamExecutionEnvironment |
st_env | StreamTableEnvironment for blink planner |
Para obtener más información sobre el uso de entornos de tablas, consulte Concepts and Common API
