Firehose

O componente Firehose (aws.greengrass.KinesisFirehose) publica dados por meio de fluxos de entrega do Amazon Data Firehose para destinos, como Amazon S3, Amazon Redshift e Amazon Service. OpenSearch Para obter mais informações, consulte O que é o Amazon Data Firehose? no Guia do desenvolvedor do Amazon Data Firehose.

Para publicar em um stream de entrega do Kinesis com esse componente, publique uma mensagem em um tópico em que esse componente se inscreva. Por padrão, esse componente se inscreve nos tópicos de kinesisfirehose/message publicação/assinatura kinesisfirehose/message/binary/# locais. Você pode especificar outros tópicos, incluindo tópicos do AWS IoT Core MQTT, ao implantar esse componente.

Versões

Esse componente tem as seguintes versões:

Tipo

Esse componente é um componente Lambda () aws.greengrass.lambda. O núcleo do Greengrass executa a função Lambda desse componente usando o componente lançador Lambda.

Para ter mais informações, consulte Tipos de componentes.

Sistema operacional

Esse componente pode ser instalado somente nos dispositivos principais do Linux.

Requisitos

Esse componente tem os seguintes requisitos:

Endpoints e portas

Esse componente deve ser capaz de realizar solicitações de saída para os seguintes endpoints e portas, além dos endpoints e portas necessários para a operação básica. Para ter mais informações, consulte Permitir o tráfego de dispositivos por meio de um proxy ou firewall.

Dependências

Quando você implanta um componente, AWS IoT Greengrass também implanta versões compatíveis de suas dependências. Isso significa que você deve atender aos requisitos do componente e de todas as suas dependências para implantá-lo com êxito. Esta seção lista as dependências das versões lançadas desse componente e as restrições de versão semântica que definem as versões dos componentes para cada dependência. Você também pode visualizar as dependências de cada versão do componente no AWS IoT Greengrass console. Na página de detalhes do componente, procure a lista de dependências.

Para obter mais informações sobre dependências de componentes, consulte a referência da receita do componente.

Configuração

Esse componente fornece os seguintes parâmetros de configuração que você pode personalizar ao implantar o componente.

{
  "lambdaExecutionParameters": {
    "EnvironmentVariables": {
      "DEFAULT_DELIVERY_STREAM_ARN": "arn:aws:firehose:us-west-2:123456789012:deliverystream/mystream"
    }
  },
  "containerMode": "GreengrassContainer"
}

{
  "lambdaExecutionParameters": {
    "EnvironmentVariables": {
      "DEFAULT_DELIVERY_STREAM_ARN": "arn:aws:firehose:us-west-2:123456789012:deliverystream/mystream"
    }
  },
  "containerMode": "NoContainer"
}

Dados de entrada

Esse componente aceita conteúdo de stream nos tópicos a seguir e envia o conteúdo para o stream de entrega de destino. O componente aceita dois tipos de dados de entrada:

Dados de saída

Por padrão, esse componente publica respostas como dados de saída no seguinte tópico do MQTT. Você deve especificar esse tópico conforme a subject configuração do componente antigo do roteador de assinatura. Para obter mais informações sobre como assinar mensagens sobre esse tópico em seus componentes personalizados, consultePublique/assine mensagens MQTT AWS IoT Core.

Tópico padrão (AWS IoT Core MQTT): kinesisfirehose/message/status

{
  "response": [
    {
      "ErrorCode": "error",
      "ErrorMessage": "test error",
      "id": "request123",
      "status": "fail"
    },
    {
      "firehose_record_id": "xyz2",
      "id": "request456",
      "status": "success"
    },
    {
      "firehose_record_id": "xyz3",
      "id": "request890",
      "status": "success"
    }
  ]
}

Arquivo de log local

Esse componente usa o seguinte arquivo de log.

/greengrass/v2/logs/aws.greengrass.KinesisFirehose.log

Licenças

Esse componente inclui o seguinte software/licenciamento de terceiros:

Esse componente é lançado de acordo com o Contrato de Licença de Software Principal do Greengrass.

Changelog

A tabela a seguir descreve as alterações em cada versão do componente.

Consulte também