计划执行与检查节点
executing-plans
按既定实施计划完成工作,保持过程检查和反馈。
configure-log-aggregation【效率与协作】LokiとPromtail(またはELKスタック)を使用して、ログの解析、ラベル抽出、 保持ポリシー、メトリクスとの相関のための統合ログ集約をセットアップする。 複数サービスのログを検索可能なシステムに統合する場合、ローカルログファイルを 集中型のクエリ可能なストレージに置き換える場合、ログをメトリクスやトレースと 相関させる場合、ラベル抽出による構造化ログを実装する場合、またはクロスサービスの ログ分析を必要とする本番インシデントのトラブルシューティングを行う場合に使用する。
独立 GitHub 快照 · 自动分类 · 以原作者文档为准
運用の可視性を確保するために、Loki/PromtailまたはELKスタックを使用して、集中型のログ収集、解析、クエリを実装する。
完全な設定ファイルとテンプレートは拡張例を参照。
要件に基づいてLoki(Prometheusスタイル)またはELK(Elasticsearchベース)から選択する。
Lokiの利点:
ELKの利点:
このガイドでは、Loki + Promtail(ほとんどの現代的なセットアップに推奨)に焦点を当てる。
判断基準:
Use Loki if:
- You want label-based queries similar to Prometheus
- Storage costs are a concern (Loki indexes only labels)
- You already use Grafana for metrics
- Kubernetes/container-native deployment
Use ELK if:
- You need full-text search across all log content
- You have complex log parsing and enrichment requirements
- You require advanced analytics and aggregations
- Legacy systems with existing Logstash pipelines
期待結果: 要件に基づいた明確な選択が行われ、チームが適切なインストールアーティファクトをダウンロードする。
失敗時:
適切なストレージバックエンドでLokiをインストールして設定する。
Docker Composeデプロイ(docker-compose.yml):
version: '3.8'
services:
loki:
image: grafana/loki:2.9.0
ports:
- "3100:3100"
volumes:
- ./loki-config.yml:/etc/loki/local-config.yaml
- loki-data:/loki
command: -config.file=/etc/loki/local-config.yaml
restart: unless-stopped
promtail:
image: grafana/promtail:2.9.0
volumes:
- ./promtail-config.yml:/etc/promtail/config.yml
- /var/log:/var/log:ro
- /var/lib/docker/containers:/var/lib/docker/containers:ro
command: -config.file=/etc/promtail/config.yml
restart: unless-stopped
depends_on:
- loki
volumes:
loki-data:
Loki設定(loki-config.yml):
auth_enabled: false
server:
http_listen_port: 3100
grpc_listen_port: 9096
# ... (see EXAMPLES.md for complete configuration)
S3ストレージを使用した本番環境向け:
storage_config:
aws:
s3: s3://us-east-1/my-loki-bucket
s3forcepathstyle: true
boltdb_shipper:
active_index_directory: /loki/index
cache_location: /loki/cache
shared_store: s3
期待結果: Lokiが正常に起動し、http://localhost:3100/readyでヘルスチェックが通過し、保持ポリシーに従ってログが保存される。
失敗時:
docker logs lokidocker run grafana/loki:2.9.0 -config.file=/etc/loki/local-config.yaml -verify-configPromtailがログをスクレイプしてLokiにラベル抽出付きで転送するよう設定する。
Promtail設定(promtail-config.yml):
server:
http_listen_port: 9080
grpc_listen_port: 0
positions:
filename: /tmp/positions.yaml
# ... (see EXAMPLES.md for complete configuration)
Promtailの主要な概念:
期待結果: Promtailが設定されたログファイルをスクレイプし、ラベルが正しく適用され、LogQLクエリを介してLokiでログが閲覧可能。
失敗時:
docker logs promtaildocker exec promtail ls /var/logcurl http://localhost:9080/metrics | grep promtailcat /tmp/positions.yamlログのフィルタリングと集計のためのLogQL構文を習得する。
基本クエリ:
# All logs from a job
{job="app"}
# Logs with specific label values
{job="app", level="error"}
# Regex filter on log line content
{job="app"} |~ "authentication failed"
# Case-insensitive regex
{job="app"} |~ "(?i)error"
# Line filter (doesn't parse, just includes/excludes)
{job="app"} |= "user" # Contains "user"
{job="app"} != "debug" # Doesn't contain "debug"
解析とフィルタリング:
# JSON parsing
{job="app"} | json | level="error"
# Regex parsing with named groups
{job="app"} | regexp "user_id=(?P<user_id>\\d+)" | user_id="12345"
# Logfmt parsing (key=value format)
{job="app"} | logfmt | level="error", service="auth"
# Pattern parsing
{job="nginx"} | pattern `<ip> - <user> [<timestamp>] "<method> <path> <protocol>" <status> <size>` | status >= 500
集計(ログからのメトリクス):
# Count log lines per level
sum by (level) (count_over_time({job="app"}[5m]))
# Rate of error logs
rate({job="app", level="error"}[5m])
# Bytes processed per service
sum by (service) (bytes_over_time({job="app"}[1h]))
# Average request duration from logs
avg_over_time({job="app"} | json | unwrap duration [5m])
# Top 10 error messages
topk(10, sum by (message) (count_over_time({level="error"} [1h])))
抽出フィールドによるフィルタリング:
# Find specific trace in logs
{job="app"} | json | trace_id="abc123def456"
# HTTP 5xx errors from nginx
{job="nginx"} | pattern `<_> "<_> <_> <_>" <status> <_>` | status >= 500
# Failed authentication attempts
{job="app"} | json | message=~"authentication failed" | user_id != ""
これらのパターンを使用してGrafana Exploreのクエリまたはダッシュボードパネルを作成する。
期待結果: クエリが期待されるログ行を返し、フィルタリングが正しく機能し、集計がログからメトリクスを生成する。
失敗時:
curl http://localhost:3100/loki/api/v1/labelscurl http://localhost:3100/loki/api/v1/label/{label_name}/values統合された可観測性のためにログをPrometheusメトリクスと分散トレースと相関させる。
ログにトレースIDを追加する(アプリケーションのインストルメンテーション):
# Python with OpenTelemetry
import logging
from opentelemetry import trace
logger = logging.getLogger(__name__)
def handle_request():
span = trace.get_current_span()
trace_id = span.get_span_context().trace_id
logger.info(
"Processing request",
extra={"trace_id": format(trace_id, "032x")}
)
// Go with OpenTelemetry
import (
"go.opentelemetry.io/otel/trace"
"go.uber.org/zap"
)
func handleRequest(ctx context.Context) {
span := trace.SpanFromContext(ctx)
traceID := span.SpanContext().TraceID().String()
logger.Info("Processing request",
zap.String("trace_id", traceID),
)
}
Grafanaデータリンクを設定する(メトリクスからログへ):
Prometheusパネルのフィールド設定:
{
"fieldConfig": {
"defaults": {
"links": [
{
"title": "View Logs",
"url": "/explore?left={\"datasource\":\"Loki\",\"queries\":[{\"refId\":\"A\",\"expr\":\"{job=\\\"app\\\",instance=\\\"${__field.labels.instance}\\\"} |= `${__field.labels.trace_id}`\"}],\"range\":{\"from\":\"${__from}\",\"to\":\"${__to}\"}}",
"targetBlank": false
}
]
}
}
}
Grafanaデータリンクを設定する(ログからトレースへ):
LokiデータソースのYAML設定:
datasources:
- name: Loki
type: loki
url: http://loki:3100
jsonData:
derivedFields:
- datasourceName: Tempo
matcherRegex: "trace_id=(\\w+)"
name: TraceID
url: "${__value.raw}"
Grafana Exploreでログを相関させる:
期待結果: メトリクスをクリックすると関連ログが開き、ログのトレースIDがトレースビューにリンクし、メトリクス/ログ/トレースのナビゲーション用の単一ペインが実現する。
失敗時:
ストレージコストを管理するために保持ポリシーとコンパクションを設定する。
ストリームによる保持(Loki設定内):
limits_config:
retention_period: 720h # Global default: 30 days
# Per-tenant retention (requires multi-tenancy enabled)
per_tenant_override_config: /etc/loki/overrides.yaml
# overrides.yaml
overrides:
production:
retention_period: 2160h # 90 days for production
staging:
retention_period: 360h # 15 days for staging
development:
retention_period: 168h # 7 days for dev
ストリームラベルによる保持(コンパクターが必要):
compactor:
working_directory: /loki/compactor
shared_store: filesystem
compaction_interval: 10m
retention_enabled: true
retention_delete_delay: 2h
# ... (see EXAMPLES.md for complete configuration)
複数のルールが一致する場合の優先度(数字が小さいほど優先度が高い)。
圧縮設定:
chunk_store_config:
chunk_cache_config:
enable_fifocache: true
fifocache:
max_size_bytes: 1GB
ttl: 24h
# ... (see EXAMPLES.md for complete configuration)
保持の監視:
# Check chunk stats
curl http://localhost:3100/loki/api/v1/status/chunks | jq
# Check compactor metrics
curl http://localhost:3100/metrics | grep loki_compactor
# Verify deleted chunks
curl http://localhost:3100/metrics | grep loki_boltdb_shipper_retention_deleted
期待結果: 保持ポリシーに従って古いログが自動的に削除され、ストレージ使用量が安定し、コンパクションによってインデックスサイズが削減される。
失敗時:
docker logs loki | grep compactorretention_enabled: trueとretention_deletes_enabled: trueを確認するdu -sh /loki/curl http://localhost:3100/readyretention_enabled: trueとretention_deletes_enabled: trueを確認する。ingestion_rate_mbとingestion_burst_size_mbを調整する。correlate-observability-signals - トレースIDを使用したメトリクス、ログ、トレースにわたる統合デバッグbuild-grafana-dashboards - ログ由来のメトリクスを可視化し、ダッシュボードにログパネルを作成するsetup-prometheus-monitoring - メトリクスはインシデント中にログをクエリするタイミングのコンテキストを提供するinstrument-distributed-tracing - 分散トレースとの相関のためにログにトレースIDを追加する