Cloud Monitor:エンティティの生成と書き込み

システムフィールド

フィールドの説明

カスタムフィールド

システムフィールドに加えて、対応する EntitySet で定義されたカスタムフィールドを含めることができます。

{
  "__domain__": "apm",
  "__entity_type__": "apm.service",
  "__entity_id__": "391274C9A1D369FB5222E273D02B81B8",
  "__method__": "Update",
  "__last_observed_time__": 1700000001,
  "__keep_alive_seconds__": 3600,
  "service_name": "user-service",
  "version": "v1.2.3",
  "cluster": "production",
  "labels": {
    "env": "prod",
    "team": "backend"
  }
}

時間範囲の概念

EntityStore の各エンティティには、定義された可視範囲があります。クエリエンジンは、クエリのタイムウィンドウがエンティティの可視時間範囲と交差する場合にのみエンティティを返します。

時間交差ロジック

クエリエンジンは、エンティティの可視範囲とクエリのタイムウィンドウが重複する場合にエンティティを返します。

An entity is returned if: QueryTimeWindow ∩ EntityVisibleTimeRange is not empty.

具体的なロジックは次のとおりです。

if (QueryEndTime >= EntityFirstObservedTime && 
    QueryStartTime < EntityVisibleEndTime) {
    // Return the entity
} else {
    // Do not return the entity
}

Create

ユースケース: Pod の作成イベントを検出した場合など、新しいエンティティを作成していることが確実な場合にのみ、このメソッドを使用します。

動作:

• エンティティが既に存在する場合、アクションは実行されません。

• エンティティが存在しない場合、指定されたフィールドで作成されます。

例:

{
  "__domain__": "k8s",
  "__entity_type__": "k8s.pod",
  "__entity_id__": "abc123...",
  "__method__": "Create",
  "__first_observed_time__": 1700000000,
  "__last_observed_time__": 1700000000,
  "pod_name": "web-app-123",
  "namespace": "default"
}

Update

ユースケース: 定期的な完全同期と増分変更に適しています。

動作:

• __first_observed_time__ を除くすべてのフィールドを上書きします。

• __first_observed_time__ の処理:

  • エンティティが存在する場合、その __first_observed_time__ は保持されます。

  • エンティティが存在せず、イベントにこのフィールドが含まれている場合、指定された値が使用されます。

  • エンティティが存在せず、イベントがこのフィールドを省略した場合、デフォルトで __last_observed_time__ の値が使用されます。

例:

{
  "__domain__": "apm",
  "__entity_type__": "apm.service",
  "__entity_id__": "def456...",
  "__method__": "Update",
  "__last_observed_time__": 1700000100,
  "service_name": "payment-service",
  "status": "running",
  "instance_count": 3
}

Expire

ユースケース: Pod の削除イベントを検出した場合など、エンティティを論理的に削除するために使用します。これにより、その履歴レコードが保持されます。

動作:

• 内部の __deleted__ フラグを true に設定します。

• __last_observed_time__ を更新します。

• KeepAliveSeconds はクエリでカウントされなくなります。

時間範囲の変更:

• 期限切れ前: [FirstObservedTime, LastObservedTime + KeepAliveSeconds)。

• 期限切れ後: [FirstObservedTime, LastObservedTime)

例:

{
  "__domain__": "k8s",
  "__entity_type__": "k8s.pod",
  "__entity_id__": "abc123...",
  "__method__": "Expire",
  "__last_observed_time__": 1700000200
}

Delete (細心の注意を払って使用)

ユースケース: 機能が無効になった場合など、エンティティをその履歴全体で非表示にする場合にのみ、このメソッドを使用します。

動作:

• データベースからエンティティレコードを物理的に消去します。

• エンティティはすべての時間範囲でクエリできなくなります。

⚠️ 警告: この操作は元に戻せません。絶対に必要な場合にのみ使用してください。

Revise (細心の注意を払って使用)

ユースケース: 誤って書き込まれたデータを強制的に修正するために使用します。多くの場合、Delete メソッドと組み合わせて使用されます。

動作:

• __first_observed_time__ を含むすべてのフィールドの完全な上書きを実行します。

• この操作は、エンティティの以前の状態を完全に無視します。

推奨戦略: 増分イベントと定期的な完全同期のハイブリッドモデル

最も堅牢な戦略は、リアルタイムの増分イベントと、データ調整およびフォールトトレランスのための定期的な完全同期を組み合わせたハイブリッドアプローチです。

設定の推奨事項:

• 増分イベント: リアルタイムまたはほぼリアルタイムで書き込みます。

• 定期的な完全同期: 周波数を 1 時間以上に設定します。

• キープアライブ時間: ビジネス要件に基づいて値を設定します。通常は 10 分から 1 時間の間です。

• 注意: __keep_alive_seconds__ は、レポート間隔よりも長くする必要があります。頻繁な更新によるパフォーマンスの低下を避けるため、5 分以上の定期的なレポート間隔を推奨します。

実践的なシナリオ

// クラウドリソース作成イベント
{
  "__domain__": "acs",
  "__entity_type__": "acs.ecs.instance",
  "__entity_id__": "i-bp1234567890",
  "__method__": "Create",
  "__first_observed_time__": 1700000000,
  "__last_observed_time__": 1700000000,
  "__keep_alive_seconds__": 86400,
  "instance_id": "i-bp1234567890",
  "instance_name": "web-server-01",
  "instance_type": "ecs.c6.large",
  "status": "Running"
}

// K8s Pod の完全収集データ
{
  "__domain__": "k8s",
  "__entity_type__": "k8s.pod",
  "__entity_id__": "pod-web-app-123",
  "__method__": "Update",
  "__last_observed_time__": 1700000400,
  "__keep_alive_seconds__": 3600,
  "pod_name": "web-app-123",
  "namespace": "production",
  "node_name": "worker-01",
  "pod_ip": "10.0.1.100",
  "labels": {
    "app": "web-app",
    "version": "v1.0"
  }
}

非推奨の取り込みパターン