Automatisation Kafka avec n8n : envoi d'updates ISS chaque minute
Ce workflow n8n a pour objectif d'envoyer des mises à jour sur la position de la Station Spatiale Internationale (ISS) à un topic Kafka chaque minute. Dans un contexte où les données en temps réel sont cruciales, ce type d'automatisation n8n permet aux entreprises de suivre des informations spatiales sans intervention manuelle. Les cas d'usage incluent la surveillance des positions satellites pour des applications de recherche ou d'éducation.
- Étape 1 : Le déclencheur est un nœud Cron qui s'active chaque minute.
- Étape 2 : Un nœud HTTP Request est utilisé pour interroger une API fournissant les coordonnées actuelles de l'ISS.
- Étape 3 : Ensuite, un nœud Set permet de structurer les données récupérées avant de les envoyer.
- Étape 4 : Enfin, les informations sont transmises à un topic Kafka via un nœud Kafka, garantissant une diffusion rapide et efficace des données. En mettant en place ce workflow, les entreprises peuvent réduire le temps de traitement des informations et améliorer la réactivité de leurs systèmes d'information. Cela représente une valeur ajoutée significative pour toute organisation souhaitant intégrer des données en temps réel dans ses processus.
Workflow n8n Kafka, ISS, données en temps réel : vue d'ensemble
Schéma des nœuds et connexions de ce workflow n8n, généré à partir du JSON n8n.
Workflow n8n Kafka, ISS, données en temps réel : détail des nœuds
Inscris-toi pour voir l'intégralité du workflow
Inscription gratuite
S'inscrire gratuitementBesoin d'aide ?{
"id": "98",
"name": "Send updates about the position of the ISS every minute to a topic in Kafka",
"nodes": [
{
"name": "Cron",
"type": "n8n-nodes-base.cron",
"position": [
510,
300
],
"parameters": {
"triggerTimes": {
"item": [
{
"mode": "everyMinute"
}
]
}
},
"typeVersion": 1
},
{
"name": "HTTP Request",
"type": "n8n-nodes-base.httpRequest",
"position": [
710,
300
],
"parameters": {
"url": "https://api.wheretheiss.at/v1/satellites/25544/positions",
"options": {},
"queryParametersUi": {
"parameter": [
{
"name": "timestamps",
"value": "={{Date.now();}}"
}
]
}
},
"typeVersion": 1
},
{
"name": "Set",
"type": "n8n-nodes-base.set",
"position": [
910,
300
],
"parameters": {
"values": {
"number": [],
"string": [
{
"name": "Name",
"value": "={{$node[\"HTTP Request\"].json[\"0\"][\"name\"]}}"
},
{
"name": "Latitude",
"value": "={{$node[\"HTTP Request\"].json[\"0\"][\"latitude\"]}}"
},
{
"name": "Longitude",
"value": "={{$node[\"HTTP Request\"].json[\"0\"][\"longitude\"]}}"
},
{
"name": "Timestamp",
"value": "={{$node[\"HTTP Request\"].json[\"0\"][\"timestamp\"]}}"
}
]
},
"options": {},
"keepOnlySet": true
},
"typeVersion": 1
},
{
"name": "Kafka",
"type": "n8n-nodes-base.kafka",
"position": [
1110,
300
],
"parameters": {
"topic": "iss-position",
"options": {}
},
"credentials": {
"kafka": "kafka"
},
"typeVersion": 1
}
],
"active": false,
"settings": {},
"connections": {
"Set": {
"main": [
[
{
"node": "Kafka",
"type": "main",
"index": 0
}
]
]
},
"Cron": {
"main": [
[
{
"node": "HTTP Request",
"type": "main",
"index": 0
}
]
]
},
"HTTP Request": {
"main": [
[
{
"node": "Set",
"type": "main",
"index": 0
}
]
]
}
}
}Workflow n8n Kafka, ISS, données en temps réel : pour qui est ce workflow ?
Ce workflow s'adresse aux entreprises et organisations qui ont besoin de suivre des données en temps réel, notamment dans les secteurs de la recherche, de l'éducation et de la technologie. Il est adapté aux équipes techniques ayant une connaissance de base des API et des systèmes de gestion de données.
Workflow n8n Kafka, ISS, données en temps réel : problème résolu
Ce workflow résout le problème de la collecte manuelle des données sur la position de l'ISS, qui peut être chronophage et sujet à des erreurs. En automatisant ce processus, les utilisateurs bénéficient d'une mise à jour continue et précise des informations, ce qui leur permet de se concentrer sur l'analyse des données plutôt que sur leur collecte. Cela réduit également le risque d'erreurs humaines et améliore l'efficacité opérationnelle.
Workflow n8n Kafka, ISS, données en temps réel : étapes du workflow
Étape 1 : Le workflow est déclenché par un nœud Cron qui s'exécute chaque minute.
- Étape 1 : Un nœud HTTP Request interroge l'API pour obtenir les coordonnées actuelles de l'ISS.
- Étape 2 : Les données récupérées sont traitées par un nœud Set qui les structure pour l'envoi.
- Étape 3 : Enfin, les informations sont envoyées à un topic Kafka via un nœud Kafka, permettant une diffusion rapide et efficace.
Workflow n8n Kafka, ISS, données en temps réel : guide de personnalisation
Pour personnaliser ce workflow, vous pouvez modifier l'URL de l'API dans le nœud HTTP Request pour interroger une autre source de données si nécessaire. Vous pouvez également ajuster les paramètres du nœud Cron pour changer la fréquence des mises à jour. Si vous souhaitez envoyer les données vers un autre service, il suffit de remplacer le nœud Kafka par un autre nœud compatible avec votre infrastructure. Assurez-vous également de sécuriser les connexions API en ajoutant des tokens d'authentification si requis.