2.2 データフローとプロセス ​

-- フレキシブル間隔設定例
UPDATE intervals:
  - 1-600: 60秒間隔で収集
  - 600-3600: 300秒間隔で収集  
  - 3600-: 600秒間隔で収集

-- history_uint テーブル構造
CREATE TABLE history_uint (
    itemid BIGINT UNSIGNED NOT NULL,
    clock INT NOT NULL,
    value BIGINT UNSIGNED NOT NULL,
    ns INT NOT NULL,
    INDEX (itemid, clock)
);

-- データ例
INSERT INTO history_uint VALUES 
(23001, 1705395025, 45, 123456789),  -- CPU使用率: 45%
(23002, 1705395025, 1024, 987654321); -- メモリ使用量: 1024MB

-- trends_uint テーブル構造
CREATE TABLE trends_uint (
    itemid BIGINT UNSIGNED NOT NULL,
    clock INT NOT NULL,
    num INT NOT NULL,
    value_min BIGINT UNSIGNED NOT NULL,
    value_avg BIGINT UNSIGNED NOT NULL,
    value_max BIGINT UNSIGNED NOT NULL,
    PRIMARY KEY (itemid, clock)
);

-- 1時間毎の統計データ例
INSERT INTO trends_uint VALUES 
(23001, 1705392000, 60, 20, 45, 85); -- CPU: 最小20%, 平均45%, 最大85%

-- MySQL パーティショニング例
ALTER TABLE history_uint PARTITION BY RANGE (clock) (
    PARTITION p2024_01 VALUES LESS THAN (UNIX_TIMESTAMP('2024-02-01 00:00:00')),
    PARTITION p2024_02 VALUES LESS THAN (UNIX_TIMESTAMP('2024-03-01 00:00:00')),
    PARTITION p2024_03 VALUES LESS THAN (UNIX_TIMESTAMP('2024-04-01 00:00:00'))
);

-- 重要なインデックス設定
CREATE INDEX idx_history_itemid_clock ON history_uint (itemid, clock);
CREATE INDEX idx_trends_itemid_clock ON trends_uint (itemid, clock);

-- 複合インデックスの例
CREATE INDEX idx_events_source_object_clock 
ON events (source, object, objectid, clock);

-- データ保持設定例
履歴データ保持期間:
- 数値データ: 30日
- 文字列データ: 7日
- ログデータ: 7日

トレンドデータ保持期間:
- 統計データ: 365日

-- 重要度別保持戦略
-- 重要メトリクス: 90日保持
UPDATE items SET history='90d' 
WHERE key_ IN ('system.cpu.util', 'vm.memory.util');

-- 一般メトリクス: 30日保持
UPDATE items SET history='30d' 
WHERE history='90d' IS FALSE;

-- ログデータ: 7日保持
UPDATE items SET history='7d' 
WHERE value_type IN (1,4); -- 文字列、ログ

-- アイテム23001（CPU使用率）の新しい値を受信
INSERT INTO history_uint VALUES (23001, 1705395085, 88, 0);

-- 関連するトリガーを特定
SELECT triggerid, expression 
FROM triggers 
WHERE expression LIKE '%23001%' 
AND status = 0; -- 有効なトリガーのみ

-- 現在のトリガー状態確認
SELECT value FROM triggers WHERE triggerid = 17001;
-- 0 = OK, 1 = PROBLEM

-- 状態変化の記録
IF (previous_state != current_state) THEN
    INSERT INTO events (eventid, source, object, objectid, clock, value)
    VALUES (nextval, 0, 0, 17001, 1705395085, 1);
END IF;

-- CPU高負荷 AND メモリ不足
{web-server-01:system.cpu.util.avg(5m)} > 80 
AND 
{web-server-01:vm.memory.util[available].last()} < 20

-- 評価プロセス:
-- 1. CPU平均値計算: 81.6% > 80% = true
-- 2. メモリ使用率確認: 15% < 20% = true
-- 3. 論理AND: true AND true = true (問題発生)

-- 継続的な高負荷（短期・中期両方）
{web-server-01:system.cpu.util.avg(5m)} > 90 
AND 
{web-server-01:system.cpu.util.avg(30m)} > 80

-- 時間窓での比較
{web-server-01:net.if.in[eth0].diff()} > 
{web-server-01:net.if.in[eth0].avg(1h)} * 2

-- ネットワーク依存関係
-- 親ルーターが停止している場合、子デバイスの障害は無視

UPDATE triggers SET status = 2 -- 依存状態
WHERE triggerid IN (
    SELECT dependent_triggerid 
    FROM trigger_depends 
    WHERE triggerid = 15001 -- 親ルーターのトリガー
) 
AND EXISTS (
    SELECT 1 FROM triggers 
    WHERE triggerid = 15001 AND value = 1 -- 親が問題状態
);

-- イベントテーブル構造
CREATE TABLE events (
    eventid BIGINT UNSIGNED NOT NULL,
    source INT NOT NULL,           -- イベントソース
    object INT NOT NULL,           -- オブジェクトタイプ  
    objectid BIGINT UNSIGNED NOT NULL, -- オブジェクトID
    clock INT NOT NULL,            -- 発生時刻
    value INT NOT NULL,            -- イベント値
    acknowledged INT NOT NULL DEFAULT 0, -- 確認状態
    severity INT NOT NULL DEFAULT 0,     -- 深刻度
    PRIMARY KEY (eventid)
);

-- トリガーイベント生成例
INSERT INTO events (
    eventid, source, object, objectid, clock, value, severity
) VALUES (
    500001, 0, 0, 17001, 1705395085, 1, 4
);
-- CPU高負荷問題発生（深刻度：重度）

-- イベント確認の記録
UPDATE events SET acknowledged = 1 
WHERE eventid = 500001;

INSERT INTO acknowledges (
    acknowledgeid, userid, eventid, clock, message, action
) VALUES (
    1001, 5, 500001, 1705395200, 'CPU負荷調査中。Apache再起動予定。', 6
);

-- 同時期の関連イベント検索
SELECT e1.objectid, t.description, e1.clock
FROM events e1
JOIN triggers t ON e1.objectid = t.triggerid
WHERE e1.clock BETWEEN 1705395000 AND 1705395300  -- 5分間
AND e1.value = 1  -- 問題イベントのみ
ORDER BY e1.clock;

-- 結果例:
-- CPU高負荷 (14:30:25)
-- メモリ不足 (14:30:45)  
-- 応答時間遅延 (14:31:10)

-- 日次イベント統計
SELECT 
    DATE(FROM_UNIXTIME(clock)) as date,
    COUNT(*) as total_events,
    SUM(CASE WHEN value = 1 THEN 1 ELSE 0 END) as problems,
    SUM(CASE WHEN value = 0 THEN 1 ELSE 0 END) as recoveries
FROM events 
WHERE source = 0  -- トリガーイベント
GROUP BY DATE(FROM_UNIXTIME(clock))
ORDER BY date DESC;

-- アクション条件設定例
アクション名: "重要サーバー障害対応"
条件:
- ホストグループ = "本番サーバー"
- 深刻度 >= "重度"
- タグ = "critical:yes"
- 時間 = 平日 9:00-18:00

-- SQL評価クエリ
SELECT actionid FROM actions a
WHERE a.status = 0  -- 有効
AND EXISTS (
    SELECT 1 FROM conditions c 
    WHERE c.actionid = a.actionid
    AND c.conditiontype = 0  -- ホストグループ条件
    AND c.value = '本番サーバー'
)
AND eventid = 500001;

-- エスカレーション設定例
CREATE TABLE escalations (
    escalationid BIGINT UNSIGNED NOT NULL,
    actionid BIGINT UNSIGNED NOT NULL,
    eventid BIGINT UNSIGNED NOT NULL,
    r_eventid BIGINT UNSIGNED NULL,
    nextcheck INT NOT NULL,
    esc_step INT NOT NULL,
    status INT NOT NULL DEFAULT 0,
    PRIMARY KEY (escalationid)
);

-- エスカレーション実行例
ステップ0 (即座): 担当者にメール
ステップ1 (15分後): 担当者にSMS + 上司にメール  
ステップ2 (30分後): チーム全体にSlack通知
ステップ3 (60分後): 管理職にSMS + 電話

-- アクションでのコマンド設定
操作タイプ: リモートコマンド
対象: 現在のホスト
コマンド: systemctl restart httpd
実行方法: SSH
ユーザー名: zabbix
認証方式: パスワード/キー

-- 通知キュー管理
CREATE TABLE alert_queue (
    alertid BIGINT UNSIGNED NOT NULL,
    actionid BIGINT UNSIGNED NOT NULL,
    eventid BIGINT UNSIGNED NOT NULL,
    userid BIGINT UNSIGNED NOT NULL,
    message TEXT NOT NULL,
    subject VARCHAR(255) NOT NULL,
    sendto VARCHAR(255) NOT NULL,
    status INT NOT NULL DEFAULT 0,
    retries INT NOT NULL DEFAULT 0,
    PRIMARY KEY (alertid)
);

-- バッチ送信処理
SELECT * FROM alert_queue 
WHERE status = 0  -- 未送信
ORDER BY alertid 
LIMIT 100;  -- 100件ずつ処理

-- 配信ログ記録
INSERT INTO alerts (
    alertid, actionid, eventid, userid, clock, 
    mediatypeid, sendto, subject, message, status
) VALUES (
    10001, 3, 500001, 5, 1705395300,
    1, '[email protected]', '【重度】CPU高負荷', '...', 1
);

-- 配信統計
SELECT 
    mediatypeid,
    COUNT(*) as total_alerts,
    SUM(CASE WHEN status = 1 THEN 1 ELSE 0 END) as sent,
    SUM(CASE WHEN status = 0 THEN 1 ELSE 0 END) as failed,
    AVG(CASE WHEN status = 1 THEN 1.0 ELSE 0.0 END) as success_rate
FROM alerts 
WHERE clock > UNIX_TIMESTAMP(DATE_SUB(NOW(), INTERVAL 24 HOUR))
GROUP BY mediatypeid;

-- MySQL最適化設定
SET GLOBAL innodb_buffer_pool_size = 2G;
SET GLOBAL innodb_log_file_size = 256M;
SET GLOBAL innodb_flush_log_at_trx_commit = 2;
SET GLOBAL sync_binlog = 0;

-- インデックス最適化
ANALYZE TABLE history_uint;
OPTIMIZE TABLE trends_uint;