Avis de fin de support : le 7 octobre 2026, AWS le support de. AWS IoT Greengrass Version 1 Après le 7 octobre 2026, vous ne pourrez plus accéder aux AWS IoT Greengrass V1 ressources. Pour plus d'informations, rendez-vous sur Migrer depuis AWS IoT Greengrass Version 1.
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
Avertissement
Ce connecteur est passé à la phase de durée de vie prolongée et AWS IoT Greengrass ne publiera pas de mises à jour fournissant des fonctionnalités, des améliorations aux fonctionnalités existantes, des correctifs de sécurité ou des corrections de bogues. Pour de plus amples informations, veuillez consulter AWS IoT Greengrass Version 1 politique de maintenance.
Le connecteur d'intégration Splunk publie les données des appareils Greengrass sur 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 les données périodiques des actionneurs et des capteurs (par exemple, les relevés de température, de pression et d'eau) pour déclencher des alarmes lorsque les valeurs dépassent certains seuils.
-
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 est disponible dans 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 un ConnectorDefinition avec une version initiale contenant 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 a un cycle de vie prolongé.
Dans la AWS IoT Greengrass console, vous pouvez ajouter un connecteur depuis la page Connecteurs du groupe. Pour de plus amples informations, veuillez consulter Mise en route avec les connecteurs Greengrass (console).
Données d'entrée
Ce connecteur accepte les données de journalisation et d'événement sur un sujet MQTT et publie les données reçues telles quelles 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
. Nécessaire :
trueType :
object. Seule la propriétéeventest obligatoire. id-
ID arbitraire de la demande. Cette propriété est utilisée pour mapper une demande d'entrée à un statut de sortie.
Nécessaire :
falseType :
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 un lot de données reçues à l'API Splunk, il publie une liste IDs des demandes réussies et échouées.
- 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_messagequi 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 réessaie de publier dans le lot suivant.
Exemple d'utilisation
Suivez les étapes de haut niveau suivantes pour configurer un exemple de fonction Lambda en 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 entre Python3.x et 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 SDK AWS IoT Greengrass principal pour Python. Ensuite, créez un package zip contenant le fichier PY et le dossier
greengrasssdkau niveau racine. Ce package zip est le package de déploiement vers lequel vous effectuez le téléchargement AWS Lambda.Après avoir créé la fonction Lambda Python 3.7, publiez une version de la 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 étant de longue durée (ou dans
"Pinned": truela CLI). -
Ajoutez la ressource secrète requise et accordez un 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 comme source, le connecteur comme cible et utilisez un filtre de rubrique d'entrée compatible.
-
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 la AWS IoT console.
-
-
-
Déployez le groupe.
-
Dans la AWS IoT console, sur la page Test, abonnez-vous à la rubrique des données de sortie pour consulter les messages d'état du connecteur. L'exemple de fonction Lambda a une longue durée de vie et commence à envoyer des messages immédiatement après le déploiement du groupe.
Lorsque vous avez terminé les tests, vous pouvez définir le cycle de vie Lambda à la demande (ou
"Pinned": falsedans la CLI) et déployer le groupe. Cela empêche la fonction d'envoyer des messages.
exemple
L'exemple suivant de fonction Lambda 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 publié dans le cadre du contrat de licence logicielle 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 de l'environnement d'exécution Lambda vers Python 3.7, ce qui modifie les exigences d'exécution. |
2 |
Correctif pour réduire la journalisation excessive. |
1 |
Première version. |
Un groupe Greengrass ne peut contenir qu'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.