返回顶部
f

fluxFlux状态引擎

Publish events and query shared world state via Flux state engine. Use when agents need to share observations, coordinate on shared data, or track entity state across systems.

作者: admin | 来源: ClawHub
源自
ClawHub
版本
V 2.3.0
安全检测
已通过
1,532
下载量
免费
免费
2
收藏
概述
安装方式
版本历史

flux

Flux 技能

Flux 是一个持久化、共享、基于事件溯源的世界状态引擎。智能体发布不可变事件,Flux 推导出所有智能体均可观察的规范状态。

核心概念

  • - 事件:不可变的观测数据(温度读数、状态变更等)
  • 实体:从事件推导出的状态对象(传感器、设备、智能体)
  • 属性:实体的键值对属性(更新时合并——仅需发送变更的属性)
  • :逻辑事件命名空间(传感器、智能体、系统)
  • 命名空间:通过令牌认证实现多租户隔离(可选,适用于公共实例)

前置条件

公共实例: https://api.flux-universe.com(命名空间在 flux-universe.com 购买——购买时自动分配名称,例如 dawn-coral)
本地实例: http://localhost:3000(默认值,可通过 FLUX_URL 环境变量覆盖)

认证:设置 FLUX_TOKEN 为你的 Bearer 令牌。公共实例必需。禁用认证的本地实例可选。

命名空间前缀

所有实体 ID 必须以你的命名空间为前缀:
yournamespace/entity-name

以命名空间 dawn-coral 为例:
bash
./scripts/flux.sh publish sensors agent-01 dawn-coral/sensor-01 \
{temperature:22.5}
./scripts/flux.sh get dawn-coral/sensor-01

在启用认证的实例上,不带命名空间前缀的实体 ID 将被拒绝。

快速开始

首先,验证你的连接:
bash
./scripts/flux.sh health

然后检查目录,查看 Flux Universe 上可用的内容:
bash
./scripts/flux.sh get flux-core/directory

目录列出所有活跃的命名空间、实体数量和总实体数——这是发现系统中数据流动情况的好方法。

脚本

使用 scripts/ 目录中提供的 bash 脚本:

  • - flux.sh - 主 CLI 工具

常用操作

发布事件

bash ./scripts/flux.sh publish id> json>

将 dawn-coral 替换为你的命名空间

示例:发布传感器读数

./scripts/flux.sh publish sensors agent-01 dawn-coral/temp-sensor-01 {temperature:22.5,unit:celsius}

查询实体状态

bash ./scripts/flux.sh get

将 dawn-coral 替换为你的命名空间

示例:获取当前传感器状态

./scripts/flux.sh get dawn-coral/temp-sensor-01

列出所有实体

bash ./scripts/flux.sh list

按前缀过滤

./scripts/flux.sh list --prefix scada/

删除实体

bash ./scripts/flux.sh delete

示例:移除旧测试实体

./scripts/flux.sh delete test/old-entity

批量发布事件

bash

将 dawn-coral 替换为你的命名空间

./scripts/flux.sh batch [ {stream:sensors,source:agent-01,payload:{entity_id:dawn-coral/sensor-01,properties:{temp:22}}}, {stream:sensors,source:agent-01,payload:{entity_id:dawn-coral/sensor-02,properties:{temp:23}}} ]

检查连接器状态

bash ./scripts/flux.sh connectors

管理配置

bash

读取运行时配置

./scripts/flux.sh admin-config

更新(需要 FLUXADMINTOKEN)

./scripts/flux.sh admin-config {ratelimitpernamespaceper_minute: 5000}

使用场景

多智能体协调

智能体向共享实体发布观测数据: bash

将 dawn-coral 替换为你的命名空间

智能体 A 观测温度

flux.sh publish sensors agent-a dawn-coral/room-101 {temperature:22.5}

智能体 B 查询当前状态

flux.sh get dawn-coral/room-101

返回:{temperature:22.5,...}

状态追踪

追踪服务/系统状态: bash

将 dawn-coral 替换为你的命名空间

发布状态变更

flux.sh publish system monitor dawn-coral/api-gateway {status:healthy,uptime:3600}

查询当前状态

flux.sh get dawn-coral/api-gateway

API 端点

事件摄入:

  • - POST /api/events — 发布单个事件(1 MB 限制)
  • POST /api/events/batch — 发布多个事件(10 MB 限制)

状态查询:

  • - GET /api/state/entities — 列出所有实体(支持 ?prefix= 和 ?namespace= 过滤器)
  • GET /api/state/entities/:id — 获取特定实体

实体管理:

  • - DELETE /api/state/entities/:id — 删除单个实体
  • POST /api/state/entities/delete — 批量删除(按命名空间/前缀/ID)

实时更新:

  • - GET /api/ws — WebSocket 订阅

连接器:

  • - GET /api/connectors — 列出连接器和状态
  • POST /api/connectors/:name/token — 存储 PAT 凭证
  • DELETE /api/connectors/:name/token — 移除凭证

管理:

  • - GET /api/admin/config — 读取运行时配置
  • PUT /api/admin/config — 更新运行时配置(需要 FLUXADMINTOKEN)

命名空间(仅认证模式):

  • - POST /api/namespaces — 注册命名空间(返回认证令牌)

注意事项

  • - 事件自动生成 UUID(无需提供 eventId)
  • 属性在更新时合并——仅发送变更的属性,现有属性保留
  • 时间戳字段必须为纪元毫秒(i64)——API 要求,由 flux.sh 自动生成
  • 状态持久化存储在 Flux 中(通过 NATS JetStream + 快照实现重启后持久化)
  • 实体 ID 支持使用 / 进行命名空间划分(例如 scada/pump-01)

标签

skill ai

通过对话安装

该技能支持在以下平台通过对话安装:

OpenClaw WorkBuddy QClaw Kimi Claude

方式一:安装 SkillHub 和技能

帮我安装 SkillHub 和 flux-1776420039 技能

方式二:设置 SkillHub 为优先技能安装源

设置 SkillHub 为我的优先技能安装源,然后帮我安装 flux-1776420039 技能

通过命令行安装

skillhub install flux-1776420039

下载

⬇ 下载 flux v2.3.0(免费)

文件大小: 8.31 KB | 发布时间: 2026-4-17 18:39

v2.3.0 最新 2026-4-17 18:39
Added Getting Started section: check flux-core/directory to discover available namespaces and data

Archiver·手机版·闲社网·闲社论坛·羊毛社区· 多链控股集团有限公司 · 苏ICP备2025199260号-1

Powered by Discuz! X5.0   © 2024-2025 闲社网·线报更新论坛·羊毛分享社区·http://xianshe.com

p2p_official_large
返回顶部