Zum Inhalt springen

Redis-Konnektor

Der Redis-Konnektor ermöglicht das Schreiben von Daten in Redis, einen In-Memory-Datenspeicher, der häufig für Caching, Nachrichtenwarteschlangen und Echtzeitanalysen verwendet wird.

Konnektor-Typen:

  • RedisWriter - Daten in Redis-Listen schreiben

Daten in eine Redis-Liste pushen:

{
"type": "RedisWriter",
"config": {
"endpoint": "localhost:6379",
"key": "sensor_data"
}
}
{
"type": "RedisWriter",
"config": {
"endpoint": "redis.example.com:6379",
"password": "your_redis_password",
"database": 0,
"key": "factory/sensors"
}
}
ParameterTypErforderlichBeschreibung
endpointstringRedis-Serveradresse (Host:Port)
keystringRedis-Listenschlüssel für Daten
passwordstringRedis-Passwort für Authentifizierung
databaseintegerRedis-Datenbanknummer (Standard: 0)

Daten werden als JSON serialisiert und mit RPUSH in die angegebene Redis-Liste gepusht:

{
"temperature": 25.5,
"pressure": 101.3,
"timestamp": 1234567890
}

Sensordaten für nachgelagerte Verarbeitung puffern:

{
"type": "RedisWriter",
"config": {
"endpoint": "localhost:6379",
"key": "sensor_queue"
}
}

In eine bestimmte Redis-Datenbank schreiben:

{
"type": "RedisWriter",
"config": {
"endpoint": "localhost:6379",
"database": 2,
"key": "production_data"
}
}

Mit einer passwortgeschützten Redis-Instanz verbinden:

{
"type": "RedisWriter",
"config": {
"endpoint": "redis.mycompany.com:6379",
"password": "secure_password",
"key": "iot_events"
}
}

Lösungen:

  • Endpoint-Adresse und Port überprüfen
  • Netzwerkverbindung und Firewall-Regeln prüfen
  • Sicherstellen, dass der Redis-Server läuft
  • Passwort überprüfen, wenn Authentifizierung aktiviert ist

Lösungen:

  • Redis-Speicherlimits prüfen
  • Schlüsselname auf Gültigkeit prüfen
  • Sicherstellen, dass die Datenbanknummer existiert
  • Redis-Logs auf Fehler prüfen
  1. Aussagekräftige Schlüssel verwenden: Schlüssel mit Namespaces organisieren (z.B. factory/line1/sensors)
  2. Listengröße überwachen: Consumer implementieren, um unbegrenztes Listenwachstum zu verhindern
  3. Geeignete Datenbank verwenden: Verschiedene Datentypen in verschiedene Datenbanken trennen
  4. Verbindungen sichern: In Produktionsumgebungen immer Passwörter verwenden
  • MQTT - Alternative Nachrichtenwarteschlange
  • MongoDB - Dokumentendatenbank-Speicher
  • InfluxDB - Zeitreihendatenbank