telefonicaiot/fiware-sth-comet

自动构建

FIWARE Short Time Historic (STH) - Comet 组件，负责存储和检索来自 Orion Context Broker 的历史原始及聚合时间序列上下文信息，通过 NGSI v1 标准接口进行通信，是 FIWARE 核心上下文管理的一部分。

0 次下载activetelefonicaiot镜像

🚀轩辕镜像专业版更稳定💎一键安装 Docker 配置镜像源

中文简介版本下载

🚀轩辕镜像专业版更稳定💎一键安装 Docker 配置镜像源

FIWARE Short Time Historic (STH) - Comet

概述

FIWARE Short Time Historic (STH) - Comet 是 FIWARE 生态系统的核心组件，负责管理（存储和检索）来自 Orion Context Broker 实例的历史上下文信息，包括原始数据和聚合时间序列数据。该组件通过标准化的 NGSI v1 接口与 Orion Context Broker 及第三方系统通信，支持上下文数据（即实体属性值）随时间变化的追踪与分析。

本项目属于 FIWARE 核心上下文管理章节，更多信息可参考 FIWARE 目录。

:books: ***文档	:whale: Docker Hub	*** Quay.io

核心功能与特性

核心功能

历史数据存储：接收 Orion Context Broker 发送的实体属性变更通知，处理并存储原始数据及聚合时间序列数据至 MongoDB 数据库。
原始数据检索：查询实体属性随时间变化的具体值及时间戳。
聚合数据检索：查询按时间分组的实体属性聚合信息，支持均值、标准差、最大值、最小值及出现次数等统计量。
数据删除：删除指定实体或属性的历史原始及聚合数据。

关键特性

遵循 NGSI v1 标准接口，确保与 FIWARE 生态系统组件的兼容性。
支持原始数据与多粒度聚合数据（如按分钟、小时、天等）的存储与查询。
基于 MongoDB 实现高效数据存储与检索。
提供 REST API 覆盖数据全生命周期管理（存储、检索、删除）。

使用场景与适用范围

适用于需要追踪和分析上下文数据随时间变化的 IoT 场景，例如：

智能城市中传感器数据（如温度、湿度、交通流量）的历史趋势分析。
工业监控系统中设备状态的长期性能评估。
环境监测中环境参数的变化模式识别。

需与 Orion Context Broker 配合使用，作为上下文数据的历史存储与分析模块。

使用方法

前提条件

已部署 Orion Context Broker 实例，用于提供上下文数据变更通知。
已部署 MongoDB 实例，用于存储历史数据（推荐 MongoDB 3.6+）。

镜像获取

可从 Docker Hub 或 Quay.io 获取镜像：

bash
# Docker Hub
docker pull telefonicaid/fiware-sth-comet

# Quay.io
docker pull quay.io/fiware/sth-comet

启动容器

基本启动命令

bash
docker run -d --name sth-comet \
  -p 8666:8666 \  # STH 服务端口
  -e STH_MONGO_URI=mongodb://<mongodb-host>:27017 \  # MongoDB 连接地址
  -e STH_ORION_URL=http://<orion-host>:1026 \  # Orion Context Broker 地址
  -e STH_SERVICE=default \  # FIWARE 服务名（与 Orion 对应）
  -e STH_SERVICEPATH=/ \  # FIWARE 服务路径（与 Orion 对应）
  telefonicaid/fiware-sth-comet

Docker Compose 示例

yaml
version: '3'
services:
  mongodb:
    image: mongo:4.4
    ports:
      - "27017:27017"
    volumes:
      - mongodb_data:/data/db

  orion:
    image: fiware/orion
    ports:
      - "1026:1026"
    depends_on:
      - mongodb
    environment:
      - ORION_MONGO_URI=mongodb://mongodb:27017/orion

  sth-comet:
    image: telefonicaid/fiware-sth-comet
    ports:
      - "8666:8666"
    depends_on:
      - mongodb
      - orion
    environment:
      - STH_MONGO_URI=mongodb://mongodb:27017
      - STH_ORION_URL=[***]
      - STH_SERVICE=default
      - STH_SERVICEPATH=/
      - STH_LOG_LEVEL=info  # 日志级别：debug/info/warn/error

volumes:
  mongodb_data:

配置参数

常用环境变量配置：

环境变量	描述	默认值
`STH_PORT`	STH 服务监听端口	8666
`STH_MONGO_URI`	MongoDB 连接 URI	mongodb://localhost:27017
`STH_ORION_URL`	Orion Context Broker 基础 URL	http://localhost:1026
`STH_SERVICE`	FIWARE 服务名（与 Orion 一致）	default
`STH_SERVICEPATH`	FIWARE 服务路径（与 Orion 一致）	/
`STH_AGGREGATION_PERIOD`	聚合周期（如：month,day,hour,minute）	minute,hour,day,month
`STH_LOG_LEVEL`	日志级别	info

API 概览

STH 提供以下核心 API 端点：

1. 数据存储

接收 Orion 发送的上下文变更通知，存储原始及聚合数据：

端点：POST /STH/v1/contextEntities/type/<entityType>/id/<entityId>/attributes/<attributeName>
说明：由 Orion 通过订阅机制自动调用，无需手动触发。

2. 原始数据检索

查询实体属性的历史原始值：

端点：GET /STH/v1/contextEntities/type/<entityType>/id/<entityId>/attributes/<attributeName>?lastN=<num>
示例：获取设备 "Device1" 的 "temperature" 属性最近 10 条原始数据：
```
bash
curl "[***]"
```

3. 聚合数据检索

查询实体属性的聚合统计数据：

端点：GET /STH/v1/contextEntities/type/<entityType>/id/<entityId>/attributes/<attributeName>?aggrMethod=<method>&dateFrom=<date>&dateTo=<date>&period=<period>
示例：获取设备 "Device1" 的 "temperature" 属性在 2023-01-01 至 2023-01-31 期间按天的平均值：
```
bash
curl "[***]"
```

4. 数据删除

删除实体或属性的历史数据：

端点：DELETE /STH/v1/contextEntities/type/<entityType>/id/<entityId>/attributes/<attributeName>
示例：删除设备 "Device1" 的 "temperature" 属性所有历史数据：
```
bash
curl -X DELETE "[***]"
```

高级主题

数据库索引优化

为提升查询性能，建议为 MongoDB 集合创建以下索引（详细可参考推荐索引文档）：

javascript
// 原始数据集合索引
db.sth_<service>_<servicepath>_raw.createIndex({ "entityId": 1, "entityType": 1, "attrName": 1, "recvTime": -1 })

// 聚合数据集合索引
db.sth_<service>_<servicepath>_aggr_<period>.createIndex({ "entityId": 1, "entityType": 1, "attrName": 1, "timeInstant": -1 })