wems

🌍 WEMS - 世界事件监测系统

🚨 面向 AI Agent 的实时自然灾害监测

一个强大的 Model Context Protocol（MCP）服务，可将 AI 助手连接到权威自然灾害数据源。监测地震、海啸、火山和太阳事件，并配置警报与 Webhook。

🤖 AI Agent： 跳过对本仓库的扫描。先阅读 AI.TOC——这是一份包含 500 个 token 的项目地图。然后使用 AI.INDEX 查找特定函数，并通过 AI.REGISTER 查找环境变量、API 和配置。本项目采用 LBF AI Navigation Standard。

⚡ 主要功能

• 🌋 9 个以上权威数据源：USGS、NOAA、Smithsonian GVP、NHC、NIFC、OpenAQ、DHS、State Dept、CISA、US Drought Monitor
• 🎯 实时监测：实时数据流，阈值可自定义
• 🔔 智能警报：针对重大事件发送 Webhook 通知
• 🗺️ 地理筛选：定位特定区域或覆盖全球
• 🔧 零配置：开箱即用，只需配置所需内容
• 🐳 可用于生产环境：支持 Docker，提供全面的错误处理

覆盖的自然灾害

灾害类型	数据源	覆盖范围
🌊 地震	USGS	全球，可按震级筛选
🌊 海啸	NOAA PTWC + CTWC	全球海洋盆地
🌋 火山	Smithsonian GVP + USGS	全球火山活动
☀️ 太阳事件	NOAA SWPC	太阳耀斑、CME、地磁风暴
🌞 空间天气警报	NOAA SWPC	正在生效的空间天气警报与预警
🌀 飓风	NHC + NWS	大西洋和太平洋热带气旋
🔥 野火	NWS + NIFC	火灾天气警报与当前火场边界
⛈️ 强对流天气	NWS Alerts	龙卷风、雷暴、洪水、冬季风暴
💨 空气质量	OpenAQ	全球 AQI、PM2.5、PM10、O₃、NO₂、SO₂、CO
🌵 干旱状况	US Drought Monitor	美国各州干旱等级（D0-D4）及趋势
🛡️ 威胁公告	DHS NTAS + State Dept + CISA	恐怖主义、旅行风险、网络威胁

🚀 快速开始

通过 PyPI 安装（推荐）

pip install wems-mcp-server

或从源代码安装

git clone https://github.com/heliosarchitect/wems-mcp-server.git
cd wems-mcp-server
pip install -r requirements.txt

基本用法

# Run as MCP server (connects to AI assistants)
python -m wems_mcp_server

# Test earthquake monitoring
python -c "
import asyncio
from wems_mcp_server import check_earthquakes
print(asyncio.run(check_earthquakes(min_magnitude=6.0)))
"

一条命令完成 AI 警报设置（Relay + n8n）

bash scripts/setup_wems_alerting_ai.sh

这将：

• 安装并启动 wems-unified-relay.service
• 更新并启用统一的 n8n 数据接入工作流
• 自动配置 tracker 发帖凭据

示例输出

{
  "earthquakes_found": 3,
  "events": [
    {
      "magnitude": 7.2,
      "location": "67 km SW of Tres Picos, Mexico",
      "time": "2024-02-13T14:30:15Z",
      "depth": 35.8,
      "tsunami_threat": true
    }
  ]
}

MCP 工具

工具	描述
check_earthquakes	查询近期地震活动
check_solar	监测空间天气（K 指数、耀斑、CME）
check_volcanoes	跟踪火山活动警报
check_tsunamis	监测海啸预警
check_hurricanes	跟踪热带气旋及其预测路径
check_wildfires	火灾天气警报与当前火场边界
check_severe_weather	监测龙卷风、雷暴、山洪
check_floods	洪水预警和 USGS 河流水位计数据
check_air_quality	监测 AQI 和污染物数据
check_threat_advisories	监测恐怖主义、旅行风险与网络威胁
check_space_weather_alerts	NOAA SWPC 发布的当前空间天气警报与预警
check_drought_status	美国各州干旱状况及 D0-D4 等级（高级版）
configure_alerts	更新警报阈值和 Webhook
fuse_multi_source_incidents	多源事件融合（由功能标志控制）

配置

alerts:
  earthquake:
    min_magnitude: 6.0
    regions: ["US", "Caribbean", "Pacific"]
    webhook: "https://your-endpoint.com/earthquake"
  
  solar:
    min_kp_index: 7  # Geomagnetic storm threshold
    webhook: "https://your-endpoint.com/solar"
    
  volcano:
    alert_levels: ["WARNING", "WATCH"]
    webhook: "https://your-endpoint.com/volcano"
    
  tsunami:
    enabled: true
    regions: ["pacific", "atlantic", "indian"]
    webhook: "https://your-endpoint.com/tsunami"

数据源

• USGS 地震灾害计划
• NOAA 太平洋海啸预警中心
• NOAA 中央海啸预警中心
• Smithsonian 全球火山活动计划
• NOAA 太空天气预报中心
• 国家飓风中心（NHC）
• 国家跨部门消防中心（NIFC）
• NWS 警报 API
• OpenAQ（全球空气质量）
• DHS 国家恐怖主义预警系统（NTAS）
• 美国国务院旅行警示
• CISA 网络安全警示

OpenClaw 集成

添加到你的 OpenClaw 配置中：

{
  "mcpServers": {
    "wems": {
      "command": "python3",
      "args": ["/path/to/wems-mcp-server/wems_mcp_server.py"],
      "env": {
        "WEMS_CONFIG": "/path/to/config.yaml"
      }
    }
  }
}

🎯 使用场景

• 🏢 企业风险管理：针对全球业务的自动化威胁评估
• 📺 新闻机构：自然灾害实时报道和警报
• 🔬 研究机构：收集数据以进行科学分析
• 🏠 个人安全：为家庭提供特定位置的灾害监测
• 🤖 AI 应急响应：与灾害响应聊天机器人集成
• 📱 警报系统：针对关键事件的自定义通知工作流

🔧 高级配置

# config.yaml - Full customization example
alerts:
  earthquake:
    min_magnitude: 6.0
    regions: ["US", "Caribbean", "Pacific"]
    webhook: "https://your-endpoint.com/earthquake"
    
  solar:
    min_kp_index: 7  # G3+ geomagnetic storm
    webhook: "https://your-endpoint.com/solar"
    
  volcano:
    alert_levels: ["WARNING", "WATCH"] 
    regions: ["Cascade Range", "Ring of Fire"]
    webhook: "https://your-endpoint.com/volcano"
    
  tsunami:
    enabled: true
    regions: ["pacific", "atlantic", "indian"]
    webhook: "https://your-endpoint.com/tsunami"

📊 监控仪表板

搭配监控工具，实现全面覆盖：

# Example: Send earthquake data to monitoring system
curl -X POST https://your-monitoring.com/api/events \
  -H "Content-Type: application/json" \
  -d "$(python -c 'import wems; print(wems.get_recent_earthquakes())')"

💳 计费与变现（当前）

WEMS 现已包含 Stripe 计量功能框架和实惠的默认定价。

当前默认定价

• 免费层级：每滚动 30 天 5,000 次调用
• 0–100,000 次调用：$0.0010/次调用
• 100,001–500,000 次调用：$0.0008/次调用
• 500,001 次以上调用：$0.0006/次调用

附加调用权重（默认）

• 大多数工具：1 个单位
• check_space_weather_alerts：2 个单位
• fuse_multi_source_incidents：3 个单位

计费配置

参见：config/wems_stripe_billing.json

关键字段：

• event_name
• api_key_to_customer
• billing_units.default
• billing_units.by_tool
• pricing.free_calls_per_rolling_30d
• pricing.tiers[]

Stripe 密钥来源

1. STRIPE_API_KEY 或 STRIPE_SECRET_KEY（直接从环境变量读取）

WEMS 会尽力查找密钥；即使密钥解析失败，也绝不会阻止警报发送。

---

由 Helios 为 AI 社区倾情打造 🌞

属于不断扩展的 OpenClaw 生态系统