View a markdown version of this page

Gestione los flujos de datos en el AWS IoT Greengrass core - AWS IoT Greengrass

Aviso de fin de soporte: el 7 de octubre de 2026, AWS descontinuará el soporte para AWS IoT Greengrass Version 1. Después del 7 de octubre de 2026, ya no podrá acceder a los AWS IoT Greengrass V1 recursos. Para obtener más información, visite Migrar desde AWS IoT Greengrass Version 1.

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.

Gestione los flujos de datos en el AWS IoT Greengrass core

AWS IoT Greengrass stream manager hace que sea más fácil y confiable transferir datos de IoT de gran volumen al Nube de AWS. Stream Manager procesa los flujos de datos de forma local y los exporta Nube de AWS automáticamente. Esta función se integra con escenarios periféricos comunes, como la inferencia mediante aprendizaje automático (ML), en la que los datos se procesan y analizan de forma local antes de exportarlos a los destinos de almacenamiento local Nube de AWS o local.

El administrador de secuencias simplifica el desarrollo de aplicaciones. Sus aplicaciones de IoT pueden utilizar un mecanismo estandarizado para procesar secuencias de gran volumen y administrar políticas de retención de datos locales en lugar de crear funciones de administración de secuencias personalizadas. Las aplicaciones de IoT pueden leer y escribir en secuencias. Pueden definir políticas para el tipo de almacenamiento, el tamaño y la retención de datos en función de cada secuencia para controlar cómo el administrador de secuencias procesa y exporta secuencias.

El administrador de secuencias está diseñado para trabajar en entornos con conectividad intermitente o limitada. Puede definir el uso del ancho de banda, el comportamiento del tiempo de espera y cómo se administran los datos de secuencias cuando el núcleo está conectado o desconectado. Para los datos críticos, puede establecer prioridades para controlar el orden en que se exportan las secuencias a la Nube de AWS.

Puede configurar las exportaciones automáticas al para su almacenamiento o Nube de AWS para su posterior procesamiento y análisis. Stream Manager admite la exportación a los siguientes Nube de AWS destinos.

  • Flujos en Kinesis Data Streams Kinesis Data Streams se suele utilizar para agregar grandes volúmenes de datos y cargarlos en un almacenamiento de datos o en un clúster de map-reduce. Para obtener más información, consulte Qué son los Amazon Kinesis Data Streams en la Guía para desarrolladores de Amazon Kinesis.

  • Propiedades de activos en AWS IoT SiteWise. AWS IoT SiteWise le permite recopilar, organizar y analizar datos de equipos industriales a escala. Para obtener más información, consulte ¿Qué es AWS IoT SiteWise? en la Guía AWS IoT SiteWise del usuario.

  • Objetos en Amazon S3. Puede utilizar Amazon S3 para almacenar y recuperar grandes cantidades de datos. Para obtener más información, consulte ¿Qué es Amazon S3? en la Guía para desarrolladores de Amazon Simple Storage Service.

nota

AWS IoT Analytics se suspendió el 15 de diciembre de 2025 y ya no es un destino de exportación admitido. Si tienes transmisiones configuradas con destinos de IoTAnalyticsConfig exportación, elimínalas para evitar que se repitan los intentos fallidos de exportación. Para obtener más información, consulte AWS IoT Analytics canales (descontinuados).

Flujo de trabajo de la administración de secuencias

Sus aplicaciones de IoT interactúan con Stream Manager a través del SDK AWS IoT Greengrass principal. En un flujo de trabajo simple, una función de Lambda definida por el usuario que se ejecuta en el núcleo de Greengrass consume los datos de IoT, como las métricas de temperatura y presión de serie temporal. La función Lambda puede filtrar o comprimir los datos y, a continuación, llamar al SDK AWS IoT Greengrass principal para escribir los datos en una transmisión en el administrador de transmisiones. El administrador de transmisiones puede exportar la transmisión Nube de AWS automáticamente, en función de las políticas definidas para la transmisión. User-defined Las funciones de Lambda también pueden enviar datos directamente a bases de datos o repositorios de almacenamiento locales.

Sus aplicaciones de IoT pueden incluir múltiples funciones de Lambda definidas por el usuario que leen o escriben en secuencias. Estas funciones de Lambda locales pueden leer y escribir en secuencias para filtrar, añadir y analizar datos localmente. Esto permite responder rápidamente a eventos locales y extraer información valiosa antes de que los datos se transfieran desde el núcleo a la nube o destinos locales.

En el siguiente diagrama se muestra un flujo de trabajo de ejemplo.

Diagrama del flujo de trabajo del administrador de secuencias.

Para usar el administrador de flujos, comience por configurar los parámetros del administrador de flujos para definir los ajustes de tiempo de ejecución a nivel de grupo que se apliquen a todas las secuencias del núcleo de Greengrass. Esta configuración personalizable le permite controlar cómo el administrador de flujos almacena, procesa y exporta secuencias en función de las necesidades de su negocio y las restricciones del entorno. Para obtener más información, consulte Configuración AWS IoT Greengrass administrador de transmisiones.

Después de configurar el administrador de flujos, puede crear e implementar sus aplicaciones de IoT. Por lo general, se trata de funciones de Lambda definidas por el usuario que se utilizan StreamManagerClient en el SDK AWS IoT Greengrass principal para crear transmisiones e interactuar con ellas. Durante la creación de la secuencia, la función de Lambda define las políticas por secuencia, como los destinos de exportación, la prioridad y la persistencia. Para obtener más información, incluidos fragmentos de código para las operaciones StreamManagerClient, consulte Se usa StreamManagerClient para trabajar con transmisiones.

Para ver tutoriales que configuran un flujo de trabajo sencillo, consulte Exporte flujos de datos a Nube de AWS (consola) o Exporte flujos de datos a Nube de AWS (CLI).

Requisitos

Se aplican los siguientes requisitos para el administrador de flujos:

  • Debes usar la versión 1.10 AWS IoT Greengrass del software Core o una versión posterior, con el administrador de transmisiones habilitado. Para obtener más información, consulte Configuración AWS IoT Greengrass administrador de transmisiones.

    El administrador de transmisiones no es compatible con las distribuciones. OpenWrt

  • Debe instalarse Java 8 Runtime (JDK 8) en el núcleo.

     

  • Stream Manager requiere un mínimo de 70 MB de RAM además del software básico AWS IoT Greengrass básico. El requisito total de memoria depende de la carga de trabajo.

     

  • User-defined Las funciones de Lambda deben usar el SDK AWS IoT Greengrass principal para interactuar con el administrador de transmisiones. El SDK AWS IoT Greengrass principal está disponible en varios idiomas, pero solo las siguientes versiones admiten las operaciones del administrador de transmisiones:

    • SDK de Java (versión 1.4.0 o posterior)

    • SDK de Python (versión 1.5.0 o posterior)

    • Node.js SDK (v1.6.0 o posterior)

    Descargue la versión del SDK que corresponda al tiempo de ejecución de la función de Lambda e inclúyala en el paquete de implementación de la función de Lambda.

    nota

    El SDK AWS IoT Greengrass principal de Python requiere Python 3.7 o una versión posterior y tiene otras dependencias de paquetes. Para obtener más información, consulte Crear un paquete de implementación de funciones de Lambda (consola) o Crear un paquete de implementación de funciones de Lambda (CLI).

  • Si defines destinos de Nube de AWS exportación para una transmisión, debes crear tus objetivos de exportación y conceder permisos de acceso en el rol de grupo de Greengrass. Según el destino, es posible que también se apliquen otros requisitos. Para obtener más información, consulte lo siguiente:

    Usted es responsable de mantener estos Nube de AWS recursos.

Seguridad de los datos

Cuando utilice el administrador de secuencias, tenga en cuenta las siguientes consideraciones de seguridad.

Seguridad de los datos locales

AWS IoT Greengrass no cifra los datos de transmisión en reposo o en tránsito de forma local entre los componentes del dispositivo principal.

  • Datos en reposo. Los datos de flujos se almacenan localmente en un directorio de almacenamiento en el núcleo de Greengrass. Para la seguridad de los datos, AWS IoT Greengrass depende de los permisos de archivos de Unix y del cifrado de disco completo, si está habilitado. Puede utilizar el parámetro opcional STREAM_MANAGER_STORE_ROOT_DIR para especificar el directorio de almacenamiento. Si cambia este parámetro más adelante para usar un directorio de almacenamiento diferente, AWS IoT Greengrass no se eliminará el directorio de almacenamiento anterior ni su contenido.

     

  • Datos en tránsito a nivel local. AWS IoT Greengrass no cifra los datos de transmisión en tránsito local en el núcleo entre las fuentes de datos, las funciones de Lambda, el SDK AWS IoT Greengrass principal y el administrador de transmisiones.

     

  • Datos en tránsito hacia el. Nube de AWS Los flujos de datos exportados por Stream Manager al cliente de AWS servicio estándar Nube de AWS utilizan el cifrado de cliente con Transport Layer Security (TLS).

Para obtener más información, consulte Cifrado de datos.

Autenticación del cliente

Los clientes de Stream Manager utilizan el SDK AWS IoT Greengrass principal para comunicarse con Stream Manager. Cuando la autenticación de cliente está habilitada, sólo las funciones de Lambda del grupo Greengrass pueden interactuar con las secuencias en el administrador de flujos. Cuando la autenticación de cliente está deshabilitada, cualquier proceso que se ejecute en el núcleo de Greengrass (como contenedores Docker) puede interactuar con las secuencias en el administrador de secuencias. Debe deshabilitar la autenticación solo si su caso de negocio lo requiere.

Utilice el parámetro STREAM_MANAGER_AUTHENTICATE_CLIENT para establecer el modo de autenticación del cliente. Puedes configurar este parámetro desde la consola o la AWS IoT Greengrass API. Los cambios surten efecto después de implementar el grupo.

  Habilitado Deshabilitado

Valor del parámetro

true (predeterminado y recomendado)

false

Clientes permitidos

User-defined Lambda funciona en el grupo Greengrass

User-defined Funciones lambda en el grupo Greengrass

Otros procesos que se ejecutan en el dispositivo del núcleo de Greengrass

Véase también