Administrador de flujos - AWS IoT Greengrass

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.

Administrador de flujos

El componente administrador de flujos (aws.greengrass.StreamManager) le permite procesar flujos de datos para transferirlos Nube de AWS desde los dispositivos principales de Greengrass.

Para obtener más información acerca de cómo configurar y usar el administrador de flujos en componentes personalizados, consulte Administración de flujos de datos en los dispositivos principales de Greengrass.

Versiones

Este componente tiene las siguientes versiones:

  • 2.2.x

  • 2.1.x

  • 2.0.x

nota

Si usa el administrador de flujos para exportar datos a la nube, no puede actualizar la versión 2.0.7 del componente de administrador de flujos a una versión entre la 2.0.8 y la 2.0.11. Si implementa el administrador de flujos por primera vez, le recomendamos que implemente la última versión del componente administrador de flujos.

Tipo

Este componente es un componente genérico (aws.greengrass.generic). El núcleo de Greengrass ejecuta los scripts del ciclo de vida del componente.

Para obtener más información, consulte Tipos de componentes.

Sistema operativo

Este componente se puede instalar en los dispositivos principales que ejecutan los siguientes sistemas operativos:

  • Linux

  • Windows

Requisitos

Este componente tiene los siguientes requisitos:

  • La función de intercambio de fichas debe permitir el acceso a los Nube de AWS destinos que utilice con el administrador de transmisiones. Para obtener más información, consulte:

  • Se admite que el componente administrador de transmisiones se ejecute en unVPC. Para implementar este componente en unVPC, se requiere lo siguiente.

    • El componente del administrador de transmisiones debe tener conectividad con el AWS servicio en el que publique los datos.

      • Amazon S3: com.amazonaws.region.s3

      • Amazon Kinesis Data Streams: com.amazonaws.region.kinesis-streams

      • AWS IoT SiteWise: com.amazonaws.region.iotsitewise.data

    • Si publica datos en Amazon S3 en la us-east-1 región, este componente intentará utilizar el punto de enlace global de S3 de forma predeterminada; sin embargo, este punto de enlace no está disponible a través del punto de enlace de la VPC interfaz de Amazon S3. Para obtener más información, consulte Restricciones y limitaciones AWS PrivateLink de Amazon S3. Para resolver este problema, puede elegir entre las siguientes opciones.

      • Configure el componente de administrador de flujos para que utilice el punto de conexión S3 de la región us-east-1, configurando -Daws.s3UseUsEast1RegionalEndpoint=regional en JVM_ARGS.

      • Cree un VPC punto de enlace de puerta de enlace de Amazon S3 en lugar de un VPC punto de enlace de interfaz de Amazon S3. Los puntos de conexión de la puerta de enlace S3 permiten el acceso al punto de conexión global de S3. Para obtener más información, consulte Creación de un punto de conexión de un gateway.

Puntos de conexión y puertos

Este componente debe poder realizar solicitudes salientes a los siguientes puntos de conexión y puertos, además de a los puntos de conexión y puertos necesarios para el funcionamiento básico. Para obtener más información, consulte Cómo permitir el tráfico del dispositivo a través de un proxy o firewall.

punto de enlace Puerto Obligatorio Descripción

iotanalytics.region.amazonaws.com

443 No

Obligatorio si publica datos en AWS IoT Analytics.

kinesis.region.amazonaws.com

443 No

Obligatorio si publica datos en Firehose.

data.iotsitewise.region.amazonaws.com

443 No

Obligatorio si publicas datos en AWS IoT SiteWise.

*.s3.amazonaws.com

443 No

Obligatorio si publica datos en buckets de S3.

Puede sustituirlos por * con el nombre de cada bucket en el que publique los datos.

Dependencias

Al implementar un componente, AWS IoT Greengrass también despliega versiones compatibles de sus dependencias. Esto significa que debe cumplir los requisitos del componente y de todas sus dependencias para poder implementar el componente correctamente. En esta sección, se enumeran las dependencias de las versiones publicadas de este componente y las restricciones de las versiones semánticas que definen las versiones de los componentes para cada dependencia. También puede ver las dependencias de cada versión del componente en la consola de AWS IoT Greengrass. En la página de detalles del componente, busque la lista de Dependencias.

2.2.0

En la siguiente tabla, se muestran las dependencias de la versión 2.2.0 de este componente.

Dependencia Versiones compatibles Tipo de dependencia
Núcleo de Greengrass >=2.0.0 <2.15.0 Flexible
Servicio de intercambio de token >=2.0.0 =2.2.0 Rígido
2.1.13

En la siguiente tabla, se muestran las dependencias de las versiones 2.1.11 a 2.1.10 de este componente.

Dependencia Versiones compatibles Tipo de dependencia
Núcleo de Greengrass >=2.0.0 <2.14.0 Flexible
Servicio de intercambio de token >=0.0.0 Rígido
2.1.11 - 2.1.12

En la siguiente tabla, se muestran las dependencias de las versiones 2.1.11 a 2.1.10 de este componente.

Dependencia Versiones compatibles Tipo de dependencia
Núcleo de Greengrass >=2.0.0 <2.13.0 Flexible
Servicio de intercambio de token >=0.0.0 Rígido
2.1.9 – 2.1.10

En la siguiente tabla, se muestran las dependencias de las versiones 2.1.9 a 2.1.10 de este componente.

Dependencia Versiones compatibles Tipo de dependencia
Núcleo de Greengrass >=2.0.0 <2.12.0 Flexible
Servicio de intercambio de token >=0.0.0 Rígido
2.1.5 – 2.1.8

En l a siguiente tabla, se muestran las dependencias de las versiones 2.1.5 a 2.1.8 de este componente.

Dependencia Versiones compatibles Tipo de dependencia
Núcleo de Greengrass >=2.0.0 <2.11.0 Flexible
Servicio de intercambio de token >=0.0.0 Rígido
2.1.2 – 2.1.4

En la siguiente tabla, se muestran las dependencias de las versiones 2.1.2 a 2.1.4 de este componente.

Dependencia Versiones compatibles Tipo de dependencia
Núcleo de Greengrass >=2.0.0 <2.10.0 Flexible
Servicio de intercambio de token >=0.0.0 Rígido
2.1.1

En la siguiente tabla, se muestran las dependencias de la versión 2.1.1 de este componente.

Dependencia Versiones compatibles Tipo de dependencia
Núcleo de Greengrass >=2.0.0 <2.9.0 Flexible
Servicio de intercambio de token >=0.0.0 Rígido
2.1.0

En la siguiente tabla, se muestran las dependencias de la versión 2.1.0 de este componente.

Dependencia Versiones compatibles Tipo de dependencia
Núcleo de Greengrass >=2.0.0 <2.8.0 Flexible
Servicio de intercambio de token >=0.0.0 Rígido
2.0.15

En la siguiente tabla, se muestran las dependencias de la versión 2.0.15 de este componente.

Dependencia Versiones compatibles Tipo de dependencia
Núcleo de Greengrass >=2.0.0 <2.7.0 Flexible
Servicio de intercambio de token >=0.0.0 Rígido
2.0.13 and 2.0.14

En la siguiente tabla, se muestran las dependencias de las versiones 2.0.13 y 2.0.14 de este componente.

Dependencia Versiones compatibles Tipo de dependencia
Núcleo de Greengrass >=2.0.0 <2.6.0 Flexible
Servicio de intercambio de token >=0.0.0 Rígido
2.0.11 and 2.0.12

En la siguiente tabla, se muestran las dependencias de las versiones 2.0.11 y 2.0.12 de este componente.

Dependencia Versiones compatibles Tipo de dependencia
Núcleo de Greengrass >=2.0.0 <2.5.0 Flexible
Servicio de intercambio de token >=0.0.0 Rígido
2.0.10

En la siguiente tabla, se muestran las dependencias de la versión 2.0.10 de este componente.

Dependencia Versiones compatibles Tipo de dependencia
Núcleo de Greengrass >=2.0.0 <2.4.0 Flexible
Servicio de intercambio de token >=0.0.0 Rígido
2.0.9

En la siguiente tabla, se muestran las dependencias de la versión 2.0.9 de este componente.

Dependencia Versiones compatibles Tipo de dependencia
Núcleo de Greengrass >=2.0.0 <2.3.0 Flexible
Servicio de intercambio de token >=0.0.0 Rígido
2.0.8

En la siguiente tabla, se muestran las dependencias de la versión 2.0.8 de este componente.

Dependencia Versiones compatibles Tipo de dependencia
Núcleo de Greengrass >=2.0.0 <2.2.0 Flexible
Servicio de intercambio de token >=0.0.0 Rígido
2.0.7

En la siguiente tabla, se muestran las dependencias de la versión 2.0.7 de este componente.

Dependencia Versiones compatibles Tipo de dependencia
Núcleo de Greengrass >=2.0.3 <2.1.0 Flexible
Servicio de intercambio de token >=0.0.0 Rígido

Para obtener más información sobre las dependencias del componente, consulte la referencia de receta de componentes.

Configuración

Este componente ofrece los siguientes parámetros de configuración que puede personalizar cuando implemente el componente.

STREAM_MANAGER_STORE_ROOT_DIR

(Opcional) La ruta absoluta del directorio local utilizado para almacenar flujos. Este valor debe comenzar con una barra inclinada (por ejemplo, /data).

Debe especificar una carpeta existente y el usuario del sistema que ejecuta el componente de administrador de flujos debe tener permisos para leer y escribir en esta carpeta. Por ejemplo, puede ejecutar los siguientes comandos para crear y configurar una carpeta, /var/greengrass/streams, que especifique como carpeta raíz del administrador de flujos. Estos comandos permiten al usuario predeterminado del sistema, ggc_user, leer y escribir en esta carpeta.

sudo mkdir /var/greengrass/streams sudo chown ggc_user /var/greengrass/streams sudo chmod 700 /var/greengrass/streams

Valor predeterminado: /greengrass/v2/work/aws.greengrass.StreamManager

STREAM_MANAGER_SERVER_PORT

(Opcional) El número de puerto local utilizado para comunicarse con el administrador de flujos.

Puede especificar 0 para usar un puerto disponible asignado al azar.

Valor predeterminado: 8088

STREAM_MANAGER_AUTHENTICATE_CLIENT

(Opcional) Puede hacer que sea obligatorio que los clientes se autentiquen antes de poder interactuar con administrador de flujos. El administrador de transmisiones SDK controla la interacción entre los clientes y el administrador de transmisiones. Este parámetro determina qué clientes pueden llamar al Stream Manager SDK para trabajar con las transmisiones. Para obtener más información, consulte Autenticación del cliente con el administrador de flujos.

Si lo especificatrue, Stream Manager solo SDK permite los componentes de Greengrass como clientes.

Si lo especificafalse, el Stream Manager SDK permite que todos los procesos del dispositivo principal sean clientes.

Valor predeterminado: true

STREAM_MANAGER_EXPORTER_MAX_BANDWIDTH

(Opcional) El ancho de banda máximo promedio (en kilobits por segundo) que el administrador de flujos puede utilizar para exportar datos.

Valor predeterminado: sin límite

STREAM_MANAGER_EXPORTER_THREAD_POOL_SIZE

(Opcional) Cantidad máxima de subprocesos activos que el administrador de flujos puede utilizar para exportar datos.

El tamaño óptimo depende del hardware, el volumen de secuencias y la cantidad planificada de secuencias de exportación. Si la velocidad de exportación es lenta, puede ajustar esta configuración para encontrar el tamaño óptimo para su hardware y su caso de negocio. La memoria CPU y la memoria del hardware de su dispositivo principal son factores limitantes. Para comenzar, puede intentar establecer este valor igual a la cantidad de núcleos de procesador en el dispositivo.

Tenga cuidado de no establecer un tamaño superior al que admite el hardware. Cada flujo utiliza recursos de hardware, por lo que debe intentar limitar la cantidad de flujos de exportación en dispositivos restringidos.

Predeterminado: 5 subprocesos

STREAM_MANAGER_EXPORTER_S3_DESTINATION_MULTIPART_UPLOAD_MIN_PART_SIZE_BYTES

(Opcional) El tamaño mínimo (en bytes) de una parte en una carga multiparte a Amazon S3. El administrador de flujos usa esta configuración y el tamaño del archivo de entrada para determinar cómo agrupar los datos en una PUT solicitud de varias partes.

nota

El administrador de flujos usa la propiedad de flujos sizeThresholdForMultipartUploadBytes para determinar si se debe exportar a Amazon S3 como una carga única o multiparte. Los componentes de AWS IoT Greengrass pueden establecer este umbral cuando crean un flujo que se exporta a Amazon S3.

Valor predeterminado: 5242880 (5 MB). Es el valor mínimo permitido.

LOG_LEVEL

(Opcional) El nivel de registro del componente. Elija uno de los siguientes niveles de registro, que se enumeran aquí en orden de niveles:

  • TRACE

  • DEBUG

  • INFO

  • WARN

  • ERROR

Valor predeterminado: INFO

JVM_ARGS

(Opcional) Argumentos personalizados de la máquina virtual de Java para pasar al administrador de flujos al inicio. Separe varios argumentos por espacios.

Utilice este parámetro solo cuando deba anular la configuración predeterminada utilizada por el. JVM Por ejemplo, puede que necesite aumentar el tamaño predeterminado del montón si planea exportar un gran número de secuencias.

ejemplo Ejemplo: actualización de la combinación de configuraciones

El siguiente ejemplo de configuración especifica el uso de un puerto no predeterminado.

{ "STREAM_MANAGER_SERVER_PORT": "18088" }

Archivo de registro local

Este componente usa el siguiente archivo de registro.

Linux
/greengrass/v2/logs/aws.greengrass.StreamManager.log
Windows
C:\greengrass\v2\logs\aws.greengrass.StreamManager.log
Visualización de los registros de este componente
  • Ejecute el siguiente comando en el dispositivo principal para ver el archivo de registro de este componente en tiempo real. Sustituya /greengrass/v2 o C:\greengrass\v2 por la ruta a la carpeta AWS IoT Greengrass raíz.

    Linux
    sudo tail -f /greengrass/v2/logs/aws.greengrass.StreamManager.log
    Windows (PowerShell)
    Get-Content C:\greengrass\v2\logs\aws.greengrass.StreamManager.log -Tail 10 -Wait

Registros de cambios

En la siguiente tabla, se describen los cambios en cada versión del componente.

Versión

Cambios

2.2.0

Nuevas características
  • Añade una nueva clave de configuración para el tiempo de espera de inicio. El valor predeterminado es 120 segundos.

  • Añade soportes de recetas para Greengrass nucleus lite.

2.1.13

Mejoras y correcciones de errores

Soporta puntos FIPS finales para AWS IoT SiteWise

2.1.12

Mejoras y correcciones de errores

Actualiza el orden en que se utilizan las credenciales, de modo que las credenciales de Greengrass son las preferidas para las solicitudes de AWS servicio.

2.1.11

Versión actualizada para el lanzamiento de la versión 2.12.0 del núcleo de Greengrass.

2.1.10

Mejoras y correcciones de errores

Soluciona un problema por el que la configuración del HTTPS proxy no confiaba en la cadena de certificados de la autoridad de certificación (CA) de Greengrass.

2.1.9

Versión actualizada para el lanzamiento de la versión 2.11.0 del núcleo de Greengrass.

2.1.8

Mejoras y correcciones de errores

Soluciona un problema que provocaba que el administrador de transmisiones volviera a intentar SiteWise exportar de forma infinita y fallaba. InvalidRequestException

2.1.7

Mejoras y correcciones de errores

Soluciona un problema por el que el administrador de flujos no podía leer correctamente la configuración del proxy.

2.1.6

Mejoras y correcciones de errores

Soluciona un problema que podía provocar un bloqueo al arrancar algunos ARMv8 procesadores, incluido el Jetson Nano.

2.1.5

Versión actualizada para el lanzamiento de la versión 2.10.0 del núcleo de Greengrass.

2.1.4

Mejoras y correcciones de errores
  • Soluciona un problema que provocaba que las entradas del mismo activo inmobiliario con la misma marca de tiempo dentro de un mismo lote fueran devueltas ConflictingOperationException desde el mismo lote, lo que provocaba SiteWise API que el administrador de transmisiones tuviera que volver a intentarlo continuamente.

  • Actualiza el tiempo de espera de conexión predeterminado de 3 segundos a 1 minuto.

2.1.3

Mejoras y correcciones de errores

Soluciona un problema de inicio en el sistema operativo Windows cuando se ejecuta como usuario. SYSTEM

2.1.2

Mejoras y correcciones de errores
  • Corrige un problema en el que el sistema operativo Windows utilizaba un idioma distinto del inglés.

  • Versión actualizada para el lanzamiento de la versión 2.9.0 del núcleo de Greengrass.

2.1.1

Versión actualizada para el lanzamiento de la versión 2.8.0 del núcleo de Greengrass.

2.1.0

Nuevas características

2.0.15

Versión actualizada para el lanzamiento de la versión 2.6.0 del núcleo de Greengrass.

2.0.14

Esta versión contiene correcciones de errores y mejoras.

2.0.13

Versión actualizada para el lanzamiento de la versión 2.5.0 del núcleo de Greengrass.

2.0.12
Mejoras y correcciones de errores

Corrige un problema que impedía actualizar el administrador de flujos versión 2.0.7 a una versión entre la versión 2.0.8 y la versión 2.0.11. Si utiliza el administrador de flujos para exportar datos a la nube, ahora puede actualizar a la versión 2.0.12.

2.0.11

Versión actualizada para el lanzamiento de la versión 2.4.0 del núcleo de Greengrass.

2.0.10

Versión actualizada para el lanzamiento de la versión 2.3.0 del núcleo de Greengrass.

2.0.9

Versión actualizada para el lanzamiento de la versión 2.2.0 del núcleo de Greengrass.

2.0.8

Versión actualizada para el lanzamiento de la versión 2.1.0 del núcleo de Greengrass.

2.0.7

Versión inicial.