Objetivo de aprendizaje

En esta guía de aprendizaje, aprenderá a crear y a ejecutar un flujo de secuencias de ejemplo. Suministramos el flujo de secuencias de ejemplo Data Historian y los datos de ejemplo. No tiene que configurar nada.

Esta guía de aprendizaje constituye una visión general, a vista de pájaro, de un flujo de secuencias y dura unos 10 minutos aproximadamente. En otras guías de aprendizaje se examina en profundidad el lienzo, la página Métricas y los operadores.

Visión general

Los datos de ejemplo se han tomado de cinco estaciones meteorológicas. Los datos incluyen ID de la estación meteorológica, huso horario, fecha en formato UTC (Tiempo universal coordinado), latitud, longitud, temperatura, presión atmosférica, humedad, temperatura interior y día lluvioso.

El flujo de secuencias de ejemplo Data Historian tiene dos operadores agregados:

• El primer operador agregado divide los datos entrantes por ID de estación meteorológica. Por lo tanto, cada estación meteorológica tiene una partición. Dentro de cada partición, los datos se agrupan por estación meteorológica. Como resultado, cada partición tiene un grupo.

  Cada 60 segundos, los datos "salen" y se aplica una función designada a los datos de cada grupo. Por ejemplo, la función Average se aplica a los datos de lluvia, pero la función Min se aplica a los datos de presión barométrica.

• El segundo operador agregado ingiere la salida del primer operador agregado. Particiona y agrupa los datos igual que el primer operador agregado, pero los datos "salen" cada 180 segundos.

  Los datos de salida del segundo operador de agregación se almacenan en Cloud Object Storage (COS) para su análisis posterior.

Vista previa

Vea este vídeo para ver cómo se crea y se ejecuta un flujo de secuencias simple utilizando un flujo de ejemplo y datos de ejemplo.

Es el momento de realizar sus propias pruebas: siga los siguientes pasos de la guía de aprendizaje en su propio entorno.

Requisitos previos

Debe tener una instancia de Cloud Object Storage (COS) y una instancia del servicio Streaming Analytics asociada al proyecto en el que se ejecuta el flujo de secuencias. Vaya a la página Proyectos del proyecto y, a continuación, pulse el separador Valores.

• En la sección Almacenamiento de la página, compruebe que se lista una instancia de COS.

• En la sección Servicios asociados de la página, compruebe que se lista un servicio Streaming Analytics.

Para suministrar una instancia, vaya a su cuenta en Panel de control de IBM Cloud. Pulse Crear recurso y, a continuación, siga las solicitudes.

Creación del flujo de secuencias de ejemplo

Cree un flujo de secuencias utilizando el flujo de secuencias de ejemplo Data Historian y sus datos de ejemplo.

1. En el menú Proyectos, pulse Ver todos los proyectos. Pulse el nombre del proyecto en el que ha colocado el nuevo flujo de secuencias.

1. En la página Proyecto, pulse el separador Activos. En el área de flujo de secuencias, pulse Nuevo flujo de secuencias.

   

2. En la página Nuevo flujo de secuencias, pulse el separador Desde ejemplo.

   

3. Siga los pasos siguientes:

   • El flujo de secuencias de ejemplo cumplimenta automáticamente los campos Nombre y Descripción, por lo que déjalos en blanco.
   • En la lista Servicio Streaming Analytics, el servicio Streaming Analytics asociado con el proyecto ya está seleccionado. Veamos un ejemplo:

   

   • En el área Seleccionar ejemplo, pulse el recuadro Ejemplo Data Historian. Observe que los campos Nombre y Descripción están ahora cumplimentados.

   • En la lista Conexión, la instancia de COS asociada al proyecto ya aparece en la lista. En el siguiente ejemplo, seleccionamos la instancia de COS "CloudObjectStorage-2w"

   • En el campo Vía de acceso de archivo, pulse el icono para abrir la ventana Seleccionar activo de datos. Seleccione un grupo y, a continuación, pulse Seleccionar.

     En este ejemplo, seleccionamos un grupo denominado “datahistorian”.
     si

   • En el campo Vía de acceso de archivo, añada la serie /%TIME. La variable %TIME añade la hora al nombre de archivo para que sea exclusivo. Añada la extensión de archivo .parquet porque el particionamiento utiliza archivos parquet.

   A continuación se muestra una vía de acceso de archivo de ejemplo para un grupo.
   

   • En la página Nuevo flujo de secuencias, pulse Crear.

Ejecución del flujo de secuencias de ejemplo

El nuevo flujo de secuencias de ejemplo Data Historian se muestra automáticamente en la página Métricas. El indicador de estado muestra que se encuentra en un estado Detenido.

Pulse el icono Ejecutar para iniciar el flujo de secuencias. El indicador de estado muestra las distintas fases a medida que se despliega el flujo de secuencias.

Observe que, hasta que el estado sea "En ejecución", el flujo de secuencias es estático utiliza flechas para conectar operadores.

Cuando el estado es En ejecución, puede ver los datos a medida que fluyen entre operadores. Coloque el puntero del ratón sobre un flujo de datos para obtener métricas en tiempo real. Pulse el flujo de datos para ver cómo fluyen los sucesos al siguiente operador.

Resumen

Acaba de crear un flujo de secuencias a partir del flujo de ejemplo Data Historian y sus datos de ejemplo. Ha iniciado un flujo de secuencias en la página Métricas y ha visto los datos de estación meteorológica que fluyen entre los operadores.

Más información

Obtenga más información sobre el flujo de secuencias de ejemplo Data Historian (su ámbito, sus operadores y su resultado) en el tema Flujo de secuencias de ejemplo Data Historian.

Para obtener más información sobre características y operadores específicos, consulte nutras otras guías de aprendizaje sobre el flujo de secuencias.