Redisコネクタ

概要

Redisコネクタは、キャッシング、メッセージキュー、リアルタイム分析に一般的に使用されるインメモリデータストアであるRedisへのデータ書き込みを可能にします。

コネクタタイプ:

RedisWriter - Redisリストにデータを書き込む

Redis Writer

Redisリストにデータをプッシュ:

{
  "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"
  }
}

設定パラメータ

パラメータ	型	必須	説明
`endpoint`	string	✅	Redisサーバーアドレス（ホスト:ポート）
`key`	string	✅	データをプッシュするRedisリストキー
`password`	string	❌	認証用Redisパスワード
`database`	integer	❌	Redisデータベース番号（デフォルト: 0）

データ形式

データはJSONとしてシリアライズされ、RPUSHを使用して指定されたRedisリストにプッシュされます:

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

一般的なユースケース

1. リアルタイムデータキュー

ダウンストリーム処理用のセンサーデータをバッファリング:

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

2. マルチデータベースセットアップ

特定のRedisデータベースに書き込み:

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

3. セキュアなリモート接続

パスワード保護されたRedisインスタンスに接続:

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

トラブルシューティング

接続失敗

解決策:

エンドポイントアドレスとポートを確認
ネットワーク接続とファイアウォールルールを確認
Redisサーバーが実行中であることを確認
認証が有効な場合はパスワードを確認

書き込み失敗