datawatch

datawatch

datawatch はデータオブザーバビリティプラットフォームの API と連携し、プラットフォームの健全性と毎日のブリーフィング、アラート（概要、受信トレイ、傾向、履歴、ルール）、監視対象のデータアセットとその検出、鮮度の概要、チェックとスケジュール、スキーマの概要、変更一覧、ベースライン、監視を扱います。1 つのバイナリで、コマンドラインインターフェースと stdio MCP サーバーの両方を提供します。

API キーが必要です。使用前に ARMOR_API_KEY を設定してください。未設定または空白の場合、リクエストを送信する前に、すべてのツールが変数名を示すエラーを返します。API のベース URL は DATAWATCH_API_URL で上書きできます。設定されていない場合、呼び出し先は https://api.anomalyarmor.ai です（ラベル付きの再構築）。

対象範囲に関する注記：プラットフォームのドキュメントには 52 個のツール名が列挙されています（見出しには 29、バージョン行には 52 と記載されており、列挙されたセクションには 52 個あります）。datawatch が実装しているのは、そのうちラベル付きコアサブセットの 24 個（アラート、アセット、鮮度、スキーマドリフト）で、メトリクス、妥当性、参照整合性、宛先、カバレッジ、推奨事項、Q&A、インテリジェンス、リネージ、ジョブ、タグ、API キーのツールは含まれていません。

インストール

npx @reneturcios/datawatch get_alerts_summary

または、コンテナイメージを実行します。

docker run -i ghcr.io/cloudcorprecords/datawatch

コンテナはデフォルトで MCP サーバーとして起動します（以下を参照）。CLI として使用するには、CLI 引数を渡してください。

CLI

サブコマンドは MCP ツール名に対応しています。

export ARMOR_API_KEY=...

datawatch health_summary
datawatch get_todays_briefing
datawatch list_alerts --status open --severity high
datawatch list_inbox_alerts --limit 20
datawatch update_alert --alert-id al1 --action acknowledge --comment "looking into it"
datawatch get_alert_trends --period 7d
datawatch list_alert_rules --asset-id a1 --is-active true
datawatch create_alert_rule --asset-id a1 --rule-type freshness --config '{"threshold_hours":24}'
datawatch list_assets --source snowflake --search orders
datawatch create_asset --name warehouse --source-type snowflake
datawatch trigger_asset_discovery --asset-id a1
datawatch check_freshness --asset-id a1 --table-path db.schema.orders
datawatch setup_freshness --asset-id a1 --table-path db.schema.orders --check-interval 1h
datawatch list_schema_changes --severity breaking
datawatch create_schema_baseline --asset-id a1 --description initial
datawatch get_schema_monitoring --asset-id a1

datawatch --version

結果は上流の JSON ペイロードとして出力されます。終了コード：成功時は 0、呼び出しの失敗時（キーがない場合や上流 API エラーを含む）は 1、使用方法のエラー時は 2 です。

MCP サーバー

1 つのバイナリで両方の機能を提供します。mcp サブコマンドで stdio MCP サーバーを起動します。

npx -y @reneturcios/datawatch mcp

MCP クライアントの設定：

{
  "mcpServers": {
    "datawatch": {
      "command": "npx",
      "args": ["-y", "@reneturcios/datawatch", "mcp"],
      "env": { "ARMOR_API_KEY": "..." }
    }
  }
}

ツール

ツール	入力	機能
health_summary	（なし）	プラットフォーム全体の健全性の概要です。
get_todays_briefing	（なし）	今日のオブザーバビリティブリーフィングです。
get_alerts_summary	（なし）	現在のアラートの概要です。
list_alerts	status、severity、asset_id、from_date、to_date	オプションのフィルターを指定してアラートを一覧表示します。
list_inbox_alerts	status、limit（整数）	受信トレイのアラートを一覧表示します。
update_alert	alert_id、action（どちらも必須）、comment	アラートにアクションを適用します。
get_alert_trends	period	指定期間のアラート傾向です。
get_alert_history	alert_id（必須）	1 件のアラートの履歴です。
list_alert_rules	asset_id、is_active（ブール値）	アラートルールを一覧表示します。
create_alert_rule	asset_id、rule_type（どちらも必須）、config（オブジェクト）	アラートルールを作成します。
manage_alert_rule	rule_id、action（どちらも必須）	アラートルールを管理します。
list_assets	source、asset_type、search	データアセットを一覧表示します。
create_asset	name、source_type（どちらも必須）、connection_config（オブジェクト）	データアセットを作成します。
manage_asset	asset_id、action（どちらも必須）	データアセットを管理します。
trigger_asset_discovery	asset_id（必須）	アセットの検出を実行します。
get_freshness_summary	（なし）	すべてのアセットの鮮度の概要です。
check_freshness	asset_id（必須）、table_path	1 つのアセットの鮮度を確認します。
setup_freshness	asset_id、table_path（どちらも必須）、check_interval	鮮度監視を設定します。
list_freshness_schedules	asset_id	鮮度スケジュールを一覧表示します。
manage_freshness_schedule	schedule_id、action（どちらも必須）	鮮度スケジュールを管理します。
get_schema_summary	（なし）	スキーマ監視の概要です。
list_schema_changes	asset_id、severity、from_date、to_date	スキーマ変更を一覧表示します。
create_schema_baseline	asset_id（必須）、description	スキーマベースラインを作成します。
get_schema_monitoring	asset_id（必須）	1 つのアセットのスキーマ監視情報です。

開発

npm install
npm run build   # tsc -> dist/
npm test        # node test runner over test/*.test.ts, no network (fake fetch fixtures)
npm run dev     # run the CLI from source via tsx

ライセンス

MIT — LICENSE を参照してください。