AWS IoT Greengrass Version 1 entró en la fase de vida útil prolongada el 30 de junio de 2023. Para obtener más información, consulte la política de mantenimiento de AWS IoT Greengrass V1 Después de esta fecha, AWS IoT Greengrass V1 no se publicarán actualizaciones que proporcionen funciones, mejoras, correcciones de errores o parches de seguridad. Los dispositivos que se ejecuten AWS IoT Greengrass V1 no se verán afectados y seguirán funcionando y conectándose a la nube. Le recomendamos encarecidamente que migre a AWS IoT Greengrass Version 2, ya que añade importantes funciones nuevas y es compatible con plataformas adicionales.
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.
Exportación de configuraciones para Nube de AWS destinos compatibles
Las funciones Lambda StreamManagerClient
definidas de Lambda definidas por el usuario deben utilizar el Core SDK AWS IoT Greengrass para interactuar con el administrador de secuencias. Cuando una función de Lambda crea un flujo o actualiza un flujo, pasa un objeto MessageStreamDefinition
que representa las propiedades del flujo, incluida la definición de exportación. El objeto ExportDefinition
contiene las configuraciones de exportación definidas para el flujo. El administrador de flujos utiliza estas configuraciones de exportación para determinar dónde y cómo exportar el flujo.
![Diagrama del modelo de objetos del tipo de propiedad ExportDefinition.](images/stream-manager-exportconfigs.png)
Puede definir cero o más configuraciones de exportación en un flujo, incluidas varias configuraciones de exportación para un único tipo de destino. Por ejemplo, puede exportar un flujo a dos canales AWS IoT Analytics y a un flujo de datos de Kinesis.
En caso de intentos fallidos de exportación, el administrador del flujo vuelve a intentar exportar los datos continuamente al Nube de AWS a intervalos de hasta cinco minutos. La cantidad de reintentos no tiene un límite máximo.
nota
StreamManagerClient
también proporciona un destino que puede utilizar para exportar secuencias a un servidor HTTP. Este destino está pensado solo con fines de prueba. No es estable y no se admite para su uso en entornos de producción.
Destinos Nube de AWS admitidos
Usted es responsable del mantenimiento de estos recursos Nube de AWS.
Canales de AWS IoT Analytics
El administrador de flujos admite la exportación automática a AWS IoT Analytics. AWS IoT Analytics le permite realizar análisis avanzados de sus datos para ayudarle a tomar decisiones de negocios y mejorar los modelos de machine learning. Para obtener más información, consulte ¿Qué es AWS IoT Analytics? en la AWS IoT Analytics Guía del usuario.
En el AWS IoT Greengrass Core SDK, las funciones de Lambda utilizan el IoTAnalyticsConfig
para definir la configuración de exportación para este tipo de destino. Para obtener más información, consulte la referencia del SDK para el lenguaje de destino.
-
IoTAnalyticsConfig
en el SDK de Python -
IoTAnalyticsConfig
en el SDK de Java -
IoTAnalyticsConfig
en el SDK de Node.js
Requisitos
Este destino de exportación tiene los siguientes requisitos:
-
Los canales de destino en AWS IoT Analytics deben estar en el mismo grupo Cuenta de AWS y Región de AWS en el grupo de Greengrass.
-
El Rol de grupo de Greengrass debe permitir el permiso
iotanalytics:BatchPutMessage
para segmentar los canales. Por ejemplo:{ "Version": "2012-10-17", "Statement": [ { "Effect": "Allow", "Action": [ "iotanalytics:BatchPutMessage" ], "Resource": [ "arn:aws:iotanalytics:
region
:account-id
:channel/channel_1_name
", "arn:aws:iotanalytics:region
:account-id
:channel/channel_2_name
" ] } ] }Puede conceder acceso granular o condicional a recursos (por ejemplo, utilizando un esquema de nomenclatura con comodín
*
) Para obtener más información, consulte Adición y eliminación de políticas de IAM en la Guía del usuario de IAM.
Exportación a AWS IoT Analytics
Para crear un flujo que se exporte a AWS IoT Analytics, las funciones de Lambda crean un flujo con una definición de exportación que incluye uno o más objetos IoTAnalyticsConfig
. Este objeto define los ajustes de exportación, como el canal de destino, el tamaño del lote, el intervalo del lote y la prioridad.
Cuando sus funciones de Lambda reciben datos de los dispositivos, anexan mensajes que contienen una masa de datos al flujo de destino.
A continuación, el administrador de flujos exporta los datos en función de los ajustes del lote y la prioridad definidos en las configuraciones de exportación del flujo.
Amazon Kinesis Data Streams
El administrador de flujos permite exportar automáticamente a Amazon 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.
En el AWS IoT Greengrass Core SDK, las funciones de Lambda utilizan el KinesisConfig
para definir la configuración de exportación para este tipo de destino. Para obtener más información, consulte la referencia del SDK para el lenguaje de destino.
-
KinesisConfig
en el SDK de Python -
KinesisConfig
en el SDK de Java -
KinesisConfig
en el SDK de Node.js
Requisitos
Este destino de exportación tiene los siguientes requisitos:
-
Las flujos de destino de Kinesis Data Streams deben estar en el mismo Cuenta de AWS y Región de AWS como grupo de Greengrass.
-
El Rol de grupo de Greengrass debe permitir el permiso
kinesis:PutRecords
para destinarse a flujos de datos. Por ejemplo:{ "Version": "2012-10-17", "Statement": [ { "Effect": "Allow", "Action": [ "kinesis:PutRecords" ], "Resource": [ "arn:aws:kinesis:
region
:account-id
:stream/stream_1_name
", "arn:aws:kinesis:region
:account-id
:stream/stream_2_name
" ] } ] }Puede conceder acceso granular o condicional a recursos (por ejemplo, utilizando un esquema de nomenclatura con comodín
*
) Para obtener información, consulte Adición y eliminación de políticas de IAM en la Guía del usuario de IAM.
Exportar a Kinesis Data Streams
Para crear un flujo que se exporte a Kinesis Data Streams, sus funciones de Lambda crean un flujo con una definición de exportación que incluye uno o más objetos KinesisConfig
. Este objeto define los ajustes de exportación, como el flujo de datos de destino, el tamaño del lote, el intervalo del lote y la prioridad.
Cuando sus funciones de Lambda reciben datos de los dispositivos, anexan mensajes que contienen una masa de datos al flujo de destino. A continuación, el administrador de flujos exporta los datos en función de los ajustes del lote y la prioridad definidos en las configuraciones de exportación del flujo.
El administrador de flujos genera un UUID aleatorio único como clave de partición para cada registro cargado en Amazon Kinesis.
AWS IoT SiteWise propiedades de activos
El administrador de flujos admite la exportación automática a 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 AWS IoT SiteWiseGuía del usuario.
En el AWS IoT Greengrass Core SDK, las funciones de Lambda utilizan el IoTSiteWiseConfig
para definir la configuración de exportación para este tipo de destino. Para obtener más información, consulte la referencia del SDK para el lenguaje de destino.
-
IoTSiteWiseConfig
en el SDK de Python -
IoTSiteWiseConfig
en el SDK de Java -
IoTSiteWiseConfig
en el SDK de Node.js
nota
AWS también proporciona la SiteWise Conector IoT, que es una solución prediseñada que puede utilizar con fuentes OPC-UA.
Requisitos
Este destino de exportación tiene los siguientes requisitos:
-
Las propiedades de los activos de destino en AWS IoT SiteWise deben estar en el mismo Cuenta de AWS y Región de AWS que el grupo Greengrass.
nota
Para la lista de las regiones que AWS IoT SiteWise admite, consulte AWS IoT SiteWiseCuotas y puntos de enlace en la Referencia general de AWS.
-
Rol de grupo de GreengrassEl
iotsitewise:BatchPutAssetPropertyValue
debe permitir que el permiso se dirija a las propiedades de los activos. El siguiente ejemplo de política utiliza la claveiotsitewise:assetHierarchyPath
de condición para conceder acceso a un activo raíz de destino y a sus elementos secundarios. Puede quitarCondition
de la política para permitir el acceso a todos sus recursos AWS IoT SiteWise o especificar ARN de los activos individuales.{ "Version": "2012-10-17", "Statement": [ { "Effect": "Allow", "Action": "iotsitewise:BatchPutAssetPropertyValue", "Resource": "*", "Condition": { "StringLike": { "iotsitewise:assetHierarchyPath": [ "/
root node asset ID
", "/root node asset ID
/*" ] } } } ] }Puede conceder acceso granular o condicional a recursos (por ejemplo, utilizando un esquema de nomenclatura con comodín
*
) Para obtener más información, consulte Adición y eliminación de políticas de IAM en la Guía del usuario de IAM.Para obtener información de seguridad importante, consulte la autorización BatchPutAssetPropertyValue en la AWS IoT SiteWiseGuía del usuario.
Exportación a AWS IoT SiteWise
Para crear un flujo que se exporte a AWS IoT SiteWise, las funciones de Lambda crean un flujo con una definición de exportación que incluye uno o más objetos IoTSiteWiseConfig
. Este objeto define los ajustes de exportación, como el tamaño del lote, el intervalo del lote y la prioridad.
Cuando sus funciones de Lambda reciben datos de propiedad de activos, anexan mensajes que contienen los datos al flujo de destino. Los mensajes son objetos PutAssetPropertyValueEntry
serializados en JSON que contienen los valores de propiedad de una o más propiedades de los activos. Para obtener más información, consulte Añadir un mensaje para los AWS IoT SiteWisedestinos de exportación.
nota
Cuando envía datos a AWS IoT SiteWise, los datos deben cumplir todos los requisitos de la acción BatchPutAssetPropertyValue
. Para obtener más información, consulte BatchPutAssetPropertyValue en la Referencia de la API AWS IoT SiteWise.
A continuación, el administrador de flujos exporta los datos en función de los ajustes del lote y la prioridad definidos en las configuraciones de exportación del flujo.
Puede ajustar los ajustes del administrador de flujos y la lógica de la función de Lambda para diseñar su estrategia de exportación. Por ejemplo:
-
Para realizar exportaciones prácticamente en tiempo real, establezca ajustes del tamaño de lote e intervalos bajos y añada los datos al flujo cuando lo reciba.
-
Para optimizar el procesamiento por lotes, mitigar las restricciones de ancho de banda o minimizar los costos, las funciones de Lambda pueden agrupar los puntos de datos de marca temporal, calidad y valor (timestamp-quality-value, TQV) recibidos para una sola propiedad de activo antes de agregar los datos al flujo. Una estrategia consiste en agrupar las entradas de hasta 10 combinaciones diferentes de propiedades y activos (o alias de propiedades) en un mensaje, en lugar de enviar más de una entrada para la misma propiedad. Esto ayuda al Administrador de flujos a mantenerse dentro de las cuotas de AWS IoT SiteWise.
Objetos de Amazon S3
El administrador de flujos permite exportar automáticamente a 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.
En el AWS IoT Greengrass Core SDK, las funciones de Lambda utilizan el S3ExportTaskExecutorConfig
para definir la configuración de exportación para este tipo de destino. Para obtener más información, consulte la referencia del SDK para el lenguaje de destino.
-
S3ExportTaskExecutorConfig
en el SDK de Python -
S3ExportTaskExecutorConfig
en el SDK de Java -
S3ExportTaskExecutorConfig
en el SDK de Node.js
Requisitos
Este destino de exportación tiene los siguientes requisitos:
-
Los buckets de Amazon S3 de destino deben estar en la misma Cuenta de AWS que el grupo de Greengrass.
-
Si la contenerización predeterminada para el grupo de Greengrass es el contenedor de Greengrass, debe configurar el parámetro STREAM_MANAGER_READ_ONLY_DIRS para usar un directorio de archivos de entrada que esté en
/tmp
o no esté en el sistema de archivos raíz. -
Si una función de Lambda que se ejecuta en el modo contenedor de Greengrass escribe archivos de entrada en el directorio de archivos de entrada, usted debe crear un recurso de volumen local para el directorio y montar el directorio en el contenedor con permisos de escritura. Esto garantiza que los archivos se escriban en el sistema de archivos raíz y que sean visibles fuera del contenedor. Para obtener más información, consulte Acceder a recursos locales con conectores y funciones de Lambda.
-
El Rol de grupo de Greengrass debe permitir los siguientes permisos para los buckets de destino. Por ejemplo:
{ "Version": "2012-10-17", "Statement": [ { "Effect": "Allow", "Action": [ "s3:PutObject", "s3:AbortMultipartUpload", "s3:ListMultipartUploadParts" ], "Resource": [ "arn:aws:s3:::
bucket-1-name
/*", "arn:aws:s3:::bucket-2-name
/*" ] } ] }Puede conceder acceso granular o condicional a recursos (por ejemplo, utilizando un esquema de nomenclatura con comodín
*
) Para obtener información, consulte Adición y eliminación de políticas de IAM en la Guía del usuario de IAM.
Exportar a Amazon S3.
Para crear un flujo que se exporte a Amazon S3, las funciones de Lambda utilizan el objeto S3ExportTaskExecutorConfig
para configurar la política de exportación. La política define los ajustes de exportación, como el umbral de carga multiparte y la prioridad. Para las exportaciones de Amazon S3, el administrador de flujos carga los datos que lee de los archivos locales en el dispositivo principal. Para iniciar una carga, sus funciones de Lambda anexan una tarea de exportación al flujo de destino. La tarea de exportación contiene información sobre el archivo de entrada y el objeto Amazon S3 de destino. El administrador de flujos ejecuta las tareas en la secuencia en que se anexan al flujo.
nota
El bucket de destino ya debe existir en su Cuenta de AWS. Si no existe un objeto para la clave especificada, el administrador de flujos crea el objeto automáticamente.
Este flujo de alto nivel se muestra en el siguiente diagrama.
![Diagrama del flujo de trabajo del administrador de secuencias para las exportaciones de Amazon S3.](images/stream-manager-s3.png)
El administrador de flujos utiliza la propiedad de umbral de carga multiparte, el ajuste del tamaño mínimo de las piezas y el tamaño del archivo de entrada para determinar cómo cargar los datos. El umbral de carga multiparte debe ser igual o mayor que el tamaño mínimo de la pieza. Si desea cargar datos en paralelo, puede crear varios flujos.
Las claves que especifican los objetos de Amazon S3 de destino pueden incluir cadenas Java DateTimeFormatter!{timestamp:
. Puede utilizar estos marcadores de fecha y hora para particionar los datos en Amazon S3 en función de la hora en la que se cargaron los datos del archivo de entrada. Por ejemplo, el siguiente nombre de clave se resuelve en un valor como value
}my-key/2020/12/31/data.txt
.
my-key/!{timestamp:YYYY}/!{timestamp:MM}/!{timestamp:dd}/data.txt
nota
Si desea supervisar el estado de exportación de un flujo, cree primero un flujo de estado y, a continuación, configure el flujo de exportación para utilizarlo. Para obtener más información, consulte Supervise las tareas de exportación.
Administrar datos de entrada
Puede crear un código que las aplicaciones de IoT usen para administrar el ciclo de vida de los datos de entrada. El siguiente ejemplo de flujo de trabajo muestra cómo se pueden utilizar las funciones de Lambda para administrar estos datos.
-
Un proceso local recibe datos de dispositivos o periféricos y, a continuación, los escribe en los archivos de un directorio del dispositivo principal. Estos son los archivos de entrada del administrador de flujos.
nota
Para determinar si debe configurar el acceso al directorio de archivos de entrada, consulte el parámetro STREAM_MANAGER_READ_ONLY_DIRS.
El proceso en el que se ejecuta el administrador de flujos hereda todos los permisos del sistema de archivos de la identidad de acceso predeterminada del grupo. El administrador de flujos debe tener permiso de acceso a los archivos de entrada. Puede utilizar el comando
chmod(1)
para cambiar el permiso de los archivos, si es necesario. -
Una función de Lambda escanea el directorio y anexa una tarea de exportación a la secuencia de destino cuando se crea un archivo nuevo. La tarea es un objeto
S3ExportTaskDefinition
serializado en JSON que especifica la URL del archivo de entrada, el bucket y la clave de Amazon S3 de destino y los metadatos de usuario opcionales. -
El administrador de flujos lee el archivo de entrada y exporta los datos a Amazon S3 en el orden de las tareas anexas. El bucket de destino ya debe existir en su Cuenta de AWS. Si no existe un objeto para la clave especificada, el administrador de flujos crea el objeto automáticamente.
-
La función de Lambda lee los mensajes de un flujo de estado para supervisar el estado de la exportación. Una vez finalizadas las tareas de exportación, la función de Lambda puede eliminar los archivos de entrada correspondientes. Para obtener más información, consulte Supervise las tareas de exportación.
Supervise las tareas de exportación
Puede crear un código que las aplicaciones de IoT utilizan para monitorear el estado de sus exportaciones de Amazon S3. Las funciones de Lambda deben crear un flujo de estado y, a continuación, configurar el flujo de exportación para escribir actualizaciones de estado en el flujo de estado. Una sola transmisión de estado puede recibir actualizaciones de estado de varias transmisiones que se exportan a Amazon S3.
En primer lugar, cree un flujo para utilizarlo como flujo de estado. Puede configurar las políticas de tamaño y retención del flujo para controlar la vida útil de los mensajes de estado. Por ejemplo:
-
Configure
Persistence
enMemory
si no desea guardar los mensajes de estado. -
Configure
StrategyOnFull
enOverwriteOldestData
para que no se pierdan los nuevos mensajes de estado.
A continuación, cree o actualice el flujo de exportación para usar el flujo de estado. En concreto, defina la propiedad de configuración de estado de la configuración de S3ExportTaskExecutorConfig
exportación del flujo. Esto le indica al administrador del flujo que escriba mensajes de estado sobre las tareas de exportación en el flujo de estado. En el objeto StatusConfig
, especifique el nombre del flujo de estado y el nivel de detalle. Los siguientes valores admitidos van desde el menos detallado (ERROR
) al más detallado (). TRACE
El valor predeterminado es INFO
.
-
ERROR
-
WARN
-
INFO
-
DEBUG
-
TRACE
El siguiente ejemplo de flujo de trabajo muestra cómo las funciones de Lambda pueden utilizar un flujo de estado para supervisar el estado de la exportación.
-
Como se describió en el flujo de trabajo anterior, una función de Lambda anexa una tarea de exportación a un flujo que está configurado para escribir mensajes de estado sobre las tareas de exportación en un flujo de estado. La operación de incorporación devuelve un número de secuencia que representa el ID de la tarea.
-
Una función de Lambda lee los mensajes secuencialmente del flujo de estado y, a continuación, filtra los mensajes en función del nombre del flujo y el identificador de la tarea o en función de una propiedad de la tarea de exportación del contexto del mensaje. Por ejemplo, la función de Lambda puede filtrar por la URL del archivo de entrada de la tarea de exportación, que está representada por el objeto
S3ExportTaskDefinition
en el contexto del mensaje.Los siguientes códigos de estado indican que una tarea de exportación ha alcanzado un estado completo:
-
Success
. Se ha completado correctamente la carga. -
Failure
. El administrador de flujos detectó un error; por ejemplo, el bucket especificado no existe. Tras resolver el problema, puede volver a añadir la tarea de exportación al flujo. -
Canceled
. La tarea se canceló porque se eliminó la definición de transmisión o exportación o porque venció el período de vida (TTL) de la tarea.
nota
La tarea también puede tener un estado de
InProgress
oWarning
. El administrador de flujos emite advertencias cuando un evento devuelve un error que no afecta a la ejecución de la tarea. Por ejemplo, si no se limpia una carga parcial cancelada, aparecerá una advertencia. -
-
Una vez finalizadas las tareas de exportación, la función de Lambda puede eliminar los archivos de entrada correspondientes.
El siguiente ejemplo muestra cómo una función de Lambda puede leer y procesar los mensajes de estado.