未復旧イベントのクエリ¶
クエリの前に、イベント関連フィールドの説明 の df_monitor_checker_event_ref、df_fault_id、df_status、df_fault_status フィールドの説明を参照してください。
1. クエリエントリ¶
2. クエリステートメント¶
方法1:HAVING 方式クエリ(Doris エンジン対応)直接結果を取得可能¶
クエリ構造¶
{
"queries": [
{
"qtype": "dql",
"query": {
"disableMultipleField": False,
"q": "E::`monitor`:(`__docid`, `df_title`,`df_monitor_checker_event_ref`, `df_fault_id`, `df_status`, `df_fault_status`,`df_fault_start_time`, `df_event_id`) { df_monitor_checker_event_ref = exists() } by `df_monitor_checker_event_ref` having df_fault_status = 'fault' sorder by create_time desc",
"timeRange": [
1724320359294,
1724323959294
],
"align_time": True,
// 今回のクエリでサンプリングを禁止する
"disable_sampling": True,
// 取得するグループ数を指定(100 個の未復旧イベント)
"slimit": 100,
"tz": "Asia/Shanghai"
},
}
]
}
方法2:非 HAVING 方式クエリ(非 Doris エンジン)フィルタリングが必要¶
クエリ構造¶
{
"queries": [
{
"qtype": "dql",
"query": {
"disableMultipleField": False,
"q": "E::`monitor`:(`__docid`, `df_title`,`df_monitor_checker_event_ref`, `df_fault_id`, `df_status`, `df_fault_status`,`df_fault_start_time`, `df_event_id`, `create_time`) { df_monitor_checker_event_ref = exists() } by `df_monitor_checker_event_ref` sorder by create_time desc",
"timeRange": [
1724320359294,
1724323959294
],
"align_time": True,
# 今回のクエリでサンプリングを禁止する
"disable_sampling": True,
# 取得するトリガー数を 1000 に指定
"slimit": 1000,
"tz": "Asia/Shanghai"
},
}
]
}
DQL クエリ結果のフィルタリング¶
クエリ結果の df_fault_status ステータスをフィルタリングし、df_fault_status=fault のイベントを抽出します。このデータが未復旧イベントのリストになります。
最終出力¶
time フィールドでデータを降順に並べ替え、最終的な未復旧イベントリストを取得します。
3. 現在のワークスペースのイベントストレージエンジンタイプを確認する方法¶
API を使用してワークスペースのストレージ情報を取得¶
API レスポンスの datastore には、現在のワークスペース内のすべての基本データのストレージエンジンタイプが格納されています(外部インデックスは除く)。datastore 内の keyevent の値が doris の場合、イベントデータが doris ストレージエンジンであることを示します。
API レスポンスの例:
{
"code": 200,
"content": {
"id": 1,
"uuid": "wksp_xxxxx",
"name": "【Doris】ワークスペース名",
"versionType": "pay",
// ......
"datastore": {
"backup_log": "doris",
"custom_object": "doris",
"keyevent": "doris", // ここで keyevent の値を確認し、doris の場合は doris ストレージエンジンタイプであることを示す
"logging": "doris",
"metric": "guancedb",
"network": "doris",
"object": "doris",
"object_history": "doris",
"profiling": "doris",
"rum": "doris",
"security": "doris",
"tracing": "doris"
},
// ......
},
"errorCode": "",
"message": "",
"success": true,
"traceId": "2956247345653191101"
}