AWS IoT Greengrass Version 1 est entré dans la phase de durée de vie prolongée le 30 juin 2023. Pour plus d'informations, consultez la politique de AWS IoT Greengrass V1 maintenance. Après cette date, AWS IoT Greengrass V1 ne publiera pas de mises à jour fournissant des fonctionnalités, des améliorations, des corrections de bogues ou des correctifs de sécurité. Les appareils qui fonctionnent AWS IoT Greengrass V1 sous tension ne seront pas perturbés et continueront à fonctionner et à se connecter au cloud. Nous vous recommandons vivement de migrer vers AWS IoT Greengrass Version 2, qui ajoute de nouvelles fonctionnalités importantes et prend en charge des plateformes supplémentaires.
Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.
Connecteur d'intégration Splunk Enterprise
Avertissement
Ce connecteur a été déplacé dans lePhase de durée, etAWS IoT Greengrassne publiera pas de mises à jour fournissant des fonctionnalités, des améliorations à des fonctionnalités existantes, des correctifs de sécurité ou des corrections de bogues. Pour plus d'informations, consultez AWS IoT Greengrass Version 1politique de maintenance.
L'intégration Splunk Enterpriseconnecteurpublie des données à partir d'appareils Greengrass dans Splunk. Cela vous permet d'utiliser Splunk pour surveiller et analyser l'environnement Greengrass Core et d'agir sur les événements locaux. Le connecteur s'intègre avec HTTP Event Collector (HEC). Pour plus d'informations, consultez la section Introduction to HTTP Event Collector
Ce connecteur reçoit la journalisation et les données d'événement dans une rubrique MQTT et publie les données en l'état dans l'API Splunk.
Vous pouvez utiliser ce connecteur pour prendre en charge des scénarios professionnels, par exemple :
-
les opérateurs peuvent utiliser des données périodiques provenant de capteurs et d'actionneurs (par exemple, la lecture des températures, de la pression et de l'eau) pour déclencher des alarmes lorsque les valeurs dépassent un certain seuil.
-
les développeurs utilisent des données collectées à partir de machines industrielles pour créer des modèles de ML qui peuvent surveiller l'équipement pour les problèmes potentiels.
Ce connecteur a les versions suivantes.
Version |
ARN |
---|---|
4 |
|
3 |
|
2 |
|
1 |
|
Pour obtenir des informations sur les changements apportés aux versions, veuillez consulter le Journal des modifications.
Prérequis
Ce connecteur possède les critères suivants :
Paramètres du connecteur
Ce connecteur fournit les paramètres suivants :
Exemple de création de connecteur (AWS CLI)
La commande CLI suivante crée unConnectorDefinition
avec une version initiale qui contient le connecteur d'intégration Splunk.
aws greengrass create-connector-definition --name MyGreengrassConnectors --initial-version '{ "Connectors": [ { "Id": "MySplunkIntegrationConnector", "ConnectorArn": "arn:aws:greengrass:
region
::/connectors/SplunkIntegration/versions/4", "Parameters": { "SplunkEndpoint": "https://myinstance.cloud.splunk.com:8088", "MemorySize": 200000, "SplunkQueueSize": 10000, "SplunkFlushIntervalSeconds": 5, "SplunkTokenSecretArn":"arn:aws:secretsmanager:region
:account-id
:secret:greengrass-secret-hash
", "SplunkTokenSecretArn-ResourceId": "MySplunkResource", "IsolationMode" : "GreengrassContainer" } } ] }'
Note
La fonction Lambda de ce connecteur possède unlongue duréecycle de vie.
DansAWS IoT Greengrass, vous pouvez ajouter un connecteur à partir de la consoleConnecteurs. Pour plus d'informations, consultez Mise en route avec les connecteurs Greengrass (console).
Données d'entrée
Ce connecteur accepte la journalisation et les données d'événement dans une rubrique MQTT et publie les données reçues en l'état dans l'API Splunk. Les messages d'entrée doivent être au format JSON.
- Filtre de rubrique dans l'abonnement
-
splunk/logs/put
- Propriétés des messages
-
request
-
Données d'événements à envoyer à l'API Splunk. Les événements doivent répondre aux spécifications de l'API services/collector
. Obligatoire :
true
Type :
object
. Seul leevent
la propriété est obligatoire. id
-
ID arbitraire de la demande. Cette propriété est utilisée pour mapper une demande d'entrée à un statut de sortie.
Obligatoire :
false
Type:
string
- Restrictions
-
Toutes les limites imposées par l'API Splunk s'appliquent lorsque ce connecteur est utilisé. Pour plus d'informations, consultez services/collector
. - Exemple d'entrée
-
{ "request": { "event": "some event", "fields": { "severity": "INFO", "category": [ "value1", "value2" ] } }, "id": "request123" }
Données de sortie
Ce connecteur publie des données de sortie dans deux rubriques :
-
Informations de statut dans la rubrique
splunk/logs/put/status
. -
Erreurs dans la rubrique
splunk/logs/put/error
.
- Filtre de rubriques :
splunk/logs/put/status
-
Utilisez cette rubrique pour écouter le statut des demandes. Chaque fois que le connecteur envoie à l'API Splunk un lot de données reçues, il publie la liste des ID des demandes qui ont réussi et celles qui ont échoué.
- Exemple de sortie
-
{ "response": { "succeeded": [ "request123", ... ], "failed": [ "request789", ... ] } }
- Filtre de rubriques :
splunk/logs/put/error
-
Utilisez cette rubrique pour écouter les erreurs du connecteur. La propriété
error_message
qui décrit l'erreur ou l'expiration rencontrée lors du traitement de la demande.- Exemple de sortie
-
{ "response": { "error": "UnauthorizedException", "error_message": "invalid splunk token", "status": "fail" } }
Note
Si le connecteur détecte une erreur réessayable (par exemple, des erreurs de connexion), il tente à nouveau la publication dans le lot suivant.
Exemple d'utilisation
Suivez les étapes détaillées suivantes pour configurer un exemple de fonction Lambda Python 3.7 que vous pouvez utiliser pour tester le connecteur.
Note
-
Si vous utilisez d'autres environnements d'exécution Python, vous pouvez créer un lien symbolique de Python 3.x vers Python 3.7.
-
Les rubriques Démarrer avec les connecteurs (console) et Démarrer avec les connecteurs (CLI) contiennent des étapes détaillées qui vous montrent comment configurer et déployer un exemple de connecteur Twilio Notifications.
-
Veillez à répondre aux conditions requises pour le connecteur.
-
Créez et publiez une fonction Lambda qui envoie des données d'entrée au connecteur.
Enregistrez l'exemple de code en tant que fichier PY. Téléchargez et décompressez le fichierAWS IoT GreengrassSDK de base pour Python. Ensuite, créez un package zip contenant le fichier PY et le dossier
greengrasssdk
au niveau racine. Ce package zip correspond au package de déploiement que vous chargez surAWS Lambda.Après avoir créé la fonction Lambda Python 3.7, publiez une version de fonction et créez un alias.
-
Configurez votre groupe Greengrass.
-
Ajoutez la fonction Lambda par son alias (recommandé). Configurez le cycle de vie Lambda comme long (ou
"Pinned": true
dans la CLI). -
Ajoutez la ressource de secret requise et accordez l'accès en lecture à la fonction Lambda.
-
Ajoutez le connecteur et configurez ses paramètres.
-
Ajoutez des abonnements qui permettent au connecteur de recevoir des données d'entrée et d'envoyer des données de sortie sur des filtres de rubrique pris en charge.
-
Définissez la fonction Lambda en tant que source, le connecteur en tant que cible et utilisez un filtre de rubrique d'entrée pris en charge.
-
Définissez le connecteur en tant que source, AWS IoT Core en tant que cible et utilisez un filtre de rubrique de sortie pris en charge. Vous utilisez cet abonnement pour afficher les messages d'état dans laAWS IoTconsole
-
-
-
Déployez le groupe.
-
DansAWS IoTsur la console, dans leTest, abonnez-vous à la rubrique des données de sortie pour afficher les messages d'état du connecteur. L'exemple de fonction Lambda à longue durée de vie commence à envoyer des messages immédiatement après le déploiement du groupe.
Lorsque vous avez terminé le test, vous pouvez définir le cycle de vie Lambda sur le type « à la demande » (
"Pinned": false
dans l'interface de ligne de commande) et déployez le groupe. Cela empêche la fonction d'envoyer des messages.
Exemple
L'exemple de fonction Lambda suivant envoie un message d'entrée au connecteur.
import greengrasssdk import time import json iot_client = greengrasssdk.client('iot-data') send_topic = 'splunk/logs/put' def create_request_with_all_fields(): return { "request": { "event": "Access log test message." }, "id" : "req_123" } def publish_basic_message(): messageToPublish = create_request_with_all_fields() print("Message To Publish: ", messageToPublish) iot_client.publish(topic=send_topic, payload=json.dumps(messageToPublish)) publish_basic_message() def lambda_handler(event, context): return
Licences
Ce connecteur est libéré sous leContrat de licence du logiciel Greengrass Core
Journal des modifications
Le tableau suivant décrit les modifications apportées à chaque version du connecteur.
Version |
Modifications |
---|---|
4 |
Ajout du paramètre |
3 |
Mise à niveau du moteur d'exécution Lambda vers Python 3.7, ce qui modifie l'exigence d'environnement d'exécution |
2 |
Correctif pour réduire la journalisation excessive. |
1 |
Première version. |
Un groupe Greengrass peut contenir une seule version du connecteur à la fois. Pour de plus amples informations sur la mise à niveau d'une version de connecteur, veuillez consulter Mise à niveau des versions du connecteur.