Sparkplug B

Name: Sparkplug B
Author: nagarjunr

作者：nagarjunrバージョン 0.1.0i★ –iパソコンで動く

レジストリ名io.github.nagarjunr/sparkplug-b

インストール

概要

作者による説明（英語の原文）

MCP server for Sparkplug B: node/device discovery, metrics, commands, host state over MQTT.

PopNx MCPの3つの柱

この3つを1つのスコアにまとめることはしません。意見、測定、人気はそれぞれ別のものだからです。

利用者の声iレビューはまだありませんレビューは今後のステップで、アカウント機能と一緒に始まります
私たちの基本チェックi1項目中1項目に合格公開情報からチェック。コードはまだスキャンしていません
利用状況i未計測★ –

できること

このサーバーのやさしい解説はまだ書いていません。以下はレジストリから読み取った事実です。

接続方法: パソコンで動く
トランスポート: stdio
カテゴリ: その他
入力が必要なもの：SPARKPLUG_MQTT_HOST, SPARKPLUG_HOST_ID, SPARKPLUG_MQTT_PASSWORD

インストール

使っているAIアプリを選んで、設定をコピーしてください。

インストールの前に

基本チェック：1項目中1項目に合格
あなたのパソコンで、あなたのユーザーと同じ権限（ファイル、ネットワーク、アプリ）で動きます。
自分で入力するもの： SPARKPLUG_MQTT_HOST, SPARKPLUG_HOST_ID, SPARKPLUG_MQTT_PORT, SPARKPLUG_MQTT_USERNAME, SPARKPLUG_MQTT_PASSWORD, SPARKPLUG_MQTT_USE_TLS, SPARKPLUG_GROUP_ID

「秘密」と表示された値は、あなたのアカウントの鍵です。絶対に人に教えたり、チャットに貼り付けたりしないでください。

必要なもの

PyPIPythonのuvのインストール（uvxコマンドに必要）

どのアプリを使っていますか？

ClaudeClaude CodeCursorVS CodeChatGPT

上でアプリを選んでください。選んだアプリを覚えておくので、次からはボタンに「…にインストール」と表示されます。

Claude Desktop → Settings → Developer → Edit Config を開き、claude_desktop_config.json にこれを貼り付けます

{
  "mcpServers": {
    "sparkplug-b": {
      "command": "uvx",
      "args": [
        "sparkplug-b-mcp-server"
      ],
      "env": {
        "SPARKPLUG_MQTT_HOST": "your-value",
        "SPARKPLUG_HOST_ID": "your-value",
        "SPARKPLUG_MQTT_PORT": "your-value",
        "SPARKPLUG_MQTT_USERNAME": "your-value",
        "SPARKPLUG_MQTT_PASSWORD": "your-value",
        "SPARKPLUG_MQTT_USE_TLS": "your-value",
        "SPARKPLUG_GROUP_ID": "your-value"
      }
    }
  }
}

ターミナルでこれを実行します

claude mcp add sparkplug-b --env SPARKPLUG_MQTT_HOST=your-value --env SPARKPLUG_HOST_ID=your-value --env SPARKPLUG_MQTT_PORT=your-value --env SPARKPLUG_MQTT_USERNAME=your-value --env SPARKPLUG_MQTT_PASSWORD=your-value --env SPARKPLUG_MQTT_USE_TLS=your-value --env SPARKPLUG_GROUP_ID=your-value -- uvx sparkplug-b-mcp-server

動かす前に、空欄の値を入力してください。

Cursorで開く

または、設定を自分でコピーする

プロジェクトの .cursor/mcp.json、または ~/.cursor/mcp.json に貼り付けます

{
  "mcpServers": {
    "sparkplug-b": {
      "command": "uvx",
      "args": [
        "sparkplug-b-mcp-server"
      ],
      "env": {
        "SPARKPLUG_MQTT_HOST": "your-value",
        "SPARKPLUG_HOST_ID": "your-value",
        "SPARKPLUG_MQTT_PORT": "your-value",
        "SPARKPLUG_MQTT_USERNAME": "your-value",
        "SPARKPLUG_MQTT_PASSWORD": "your-value",
        "SPARKPLUG_MQTT_USE_TLS": "your-value",
        "SPARKPLUG_GROUP_ID": "your-value"
      }
    }
  }
}

ブラウザがアプリを開いてよいか確認し、そのあとアプリが設定を表示して確認を求めます。キーの値は空欄のままなので、自分で入力してください。

VS Codeで開く

または、設定を自分でコピーする

プロジェクトの .vscode/mcp.json に貼り付けます

{
  "servers": {
    "sparkplug-b": {
      "type": "stdio",
      "command": "uvx",
      "args": [
        "sparkplug-b-mcp-server"
      ],
      "env": {
        "SPARKPLUG_MQTT_HOST": "your-value",
        "SPARKPLUG_HOST_ID": "your-value",
        "SPARKPLUG_MQTT_PORT": "your-value",
        "SPARKPLUG_MQTT_USERNAME": "your-value",
        "SPARKPLUG_MQTT_PASSWORD": "your-value",
        "SPARKPLUG_MQTT_USE_TLS": "your-value",
        "SPARKPLUG_GROUP_ID": "your-value"
      }
    }
  }
}

これはパソコンで動くサーバーですが、ChatGPTがつなげるのはインターネット上のサーバーだけです。ほかのアプリを選んでください。

選んだアプリは、この端末のCookieに保存されます。アカウントは不要です。

自分で入力する値

SPARKPLUG_MQTT_HOST 必須 env
MQTT broker hostname or IP.
SPARKPLUG_HOST_ID 必須 env
This connector's Sparkplug Host Application ID (used in the spBv1.0/STATE/{id} topic).
SPARKPLUG_MQTT_PORT env
MQTT broker port, default 1883
SPARKPLUG_MQTT_USERNAME env
Broker username, if required
SPARKPLUG_MQTT_PASSWORD 秘密 env
Broker password, if required
SPARKPLUG_MQTT_USE_TLS env
true/false, default false
SPARKPLUG_GROUP_ID env
Restrict discovery/watching to a single Sparkplug Group ID; omit to subscribe to every group

この設定は、作者のレジストリ登録情報から作成しています。READMEと違う場合は、READMEに従ってください。

できること

パソコンで動くサーバーです。インストールすると、ツール一覧がAIアプリに表示されます。

基本チェックi

誰でも見られる情報をチェックしており、コードは読んでいません。当てはまらない項目は数に入れていません。 · 2026年11月6日にチェック

✓ 合格
作者とリポジトリが一致
レジストリ名は、リポジトリを所有するGitHubアカウント nagarjunr で確認済みです
… 未チェック
今もメンテナンスされている
このリポジトリはまだGitHubから読み取っていません
… 未チェック
ライセンスがある
このリポジトリはまだGitHubから読み取っていません
– 対象外
エンドポイントが応答する
これはパソコンで動くため、インターネット上のエンドポイントはありません
– 対象外
OAuthでサインイン
パソコンで動き、代わりにローカルの設定を使います
… 未チェック
ツールの説明に隠れた指示がない
パソコンで動くサーバーです。ツール一覧を読み取れるのは、インターネット上のエンドポイントがある場合だけです

その他のほかのサーバーとの比較i

このカテゴリのほかの32435件のうち0%よりスターが多い
このカテゴリのほかの32435件のうち21%より最近レジストリに公開
基本チェックの結果が、このカテゴリのほかの32435件のうち100%と同じかそれ以上

レジストリでこのカテゴリにある有効なすべてのサーバーと比較しています。スターは、公開者がリポジトリの所有者である場合だけ数えます。

よくある質問

Sparkplug Bは安全ですか？

当てはまる基本チェック1項目のうち1項目に合格しました。コードは読んでいません。キーやトークンを追加する前に、サーバーがどんなアクセスを求めているかを確認し、必要な権限だけを持つキーを使ってください。

どんなキーやコードが必要ですか？

入力が必要なもの：SPARKPLUG_MQTT_HOST, SPARKPLUG_HOST_ID, SPARKPLUG_MQTT_PASSWORD

パソコンで動きますか、それともクラウドですか？

あなたのパソコンで動きます。必要なときにAIアプリが起動し、データは作者のサーバーを通りません（サーバー自体がオンラインサービスを呼び出す場合を除きます）。

今もメンテナンスされていますか？

GitHubリポジトリの最終更新は–、最新バージョン（0.1.0）がレジストリに届いたのは3 か月前です。

どのアプリで使えますか？

Claude Desktop、Claude Code、Cursor、VS CodeなどのMCP対応アプリで使えます。パソコンにPython (uv)も必要です。

代わりに使えるものは？

同じカテゴリには：Spec Driven Development, Remote Desktop Commander, Apify MCP Server

代わりの候補

同じカテゴリで、ほかの作者が作ったサーバー。スターの多い順。

カードの見方：★ GitHubスターi3つの柱：レビュー · チェック · 利用状況i更新＝最新バージョンをレジストリに公開した日i

Spec Driven Development

作者：formulahendry

MCP Server that facilitates spec-driven development workflows, not just Vibe Coding.

パソコンで動く★ 440MIT14 か月前更新

インストール

Remote Desktop Commander

作者：desktop-commander

Remote Desktop Commander: use files, terminal and processes on your own computers from any AI app.

クラウドで動く★ 211昨日更新

インストール

Apify MCP Server

作者：apify

Extract data from any website with thousands of scrapers, crawlers, and automations on Apify Store ⚡

クラウドで動く今日更新

インストール

作者のREADME

READMEを開く

作者のリポジトリから書かれたとおりにコピーしたものです。PopNx MCPは内容を確認・推奨していません。HTML、画像、スクリプトは取り除いています。リンクはこのサイトの外へ移動します。

Sparkplug B MCP Server

A Model Context Protocol (MCP) server for Sparkplug B — the Eclipse-standard MQTT topic/payload convention for industrial/SCADA data (birth/death certificates, sequenced metrics, protobuf payloads). Works against any MQTT broker that carries Sparkplug B traffic; only the open Sparkplug B specification is used, no vendor-specific extensions.

This server acts as a Sparkplug B Primary Host Application: it subscribes to the entire spBv1.0 namespace, discovers Edge Nodes and Devices from their NBIRTH/DBIRTH messages, tracks their live metrics, and can send them commands (NCMD/DCMD) — the same role a SCADA/historian host application plays in a real deployment.

Built with FastMCP and pysparkplug (itself built on paho-mqtt).

Tools

Tool	Description
`get_connection_status()`	Report the broker connection and this host application's identity.
`set_host_online(online)`	Publish this connector's own retained Sparkplug `STATE` message.
`list_edge_nodes(group_id?)`	List Edge Nodes discovered via `NBIRTH`/`NDEATH`.
`list_devices(group_id?, edge_node_id?)`	List Devices discovered via `DBIRTH`/`DDEATH`.
`get_node_metrics(group_id, edge_node_id)`	Latest known metric values for an Edge Node.
`get_device_metrics(group_id, edge_node_id, device_id)`	Latest known metric values for a Device.
`send_node_command(group_id, edge_node_id, metrics)`	Send an `NCMD` — write one or more of a node's metrics.
`send_device_command(group_id, edge_node_id, device_id, metrics)`	Send a `DCMD` — write one or more of a device's metrics.
`request_node_rebirth(group_id, edge_node_id)`	Standard `Node Control/Rebirth` command — asks a node to republish its full `NBIRTH`.
`start_watch(group_id?, edge_node_id?, device_id?, message_types?)`	Start buffering decoded Sparkplug traffic matching an optional filter. Returns a `session_id`.
`get_events(session_id, max_events, timeout_seconds)`	Drain buffered events from a watch session; can wait briefly for one to arrive.
`stop_watch(session_id)`	Stop a watch session and discard its buffered events.
`list_watches()`	List all active watch sessions.

Why watching is session-based

Like the MQTT wire protocol underneath it, Sparkplug B is a continuous stream, not a request/response API — a single MCP tool call can't "wait forever" for the next birth or data message. start_watch registers an optional filter (group/node/device/message-type) and buffers matching decoded messages in the background (this connector is always subscribed to the whole spBv1.0 namespace, so no extra broker subscription is needed per watch); get_events drains that buffer, optionally waiting a bounded amount of time for new data. Call stop_watch when done.

Supported metric datatypes

INT8/INT16/INT32/INT64, UINT8/UINT16/UINT32/UINT64, FLOAT, DOUBLE, BOOLEAN, STRING, TEXT, UUID, DATETIME, BYTES, FILE, and their *_ARRAY variants. DATASET, TEMPLATE, PROPERTYSET, and PROPERTYSETLIST are part of the Sparkplug B spec but unsupported by the underlying pysparkplug codec, so they're rejected with a clear error rather than silently mishandled.

For send_node_command/send_device_command, value shape depends on datatype: plain int/float/bool/str for scalars, an ISO 8601 string for DATETIME, a base64 string for BYTES/FILE, and a JSON list for *_ARRAY types.

Configuration

Env var	Required	Description
`SPARKPLUG_MQTT_HOST`	Yes	Broker hostname or IP.
`SPARKPLUG_HOST_ID`	Yes	This connector's Sparkplug Host Application ID (used in the `spBv1.0/STATE/{id}` topic).
`SPARKPLUG_MQTT_PORT`	No	Default `1883`.
`SPARKPLUG_MQTT_USERNAME` / `SPARKPLUG_MQTT_PASSWORD`	No	Broker credentials.
`SPARKPLUG_MQTT_CLIENT_ID`	No	Defaults to a broker-assigned ID.
`SPARKPLUG_MQTT_KEEPALIVE`	No	Seconds, default `60`.
`SPARKPLUG_MQTT_CONNECT_TIMEOUT`	No	Seconds to wait for the initial connect, default `10`.
`SPARKPLUG_MQTT_USE_TLS`	No	`true`/`false`, default `false`.
`SPARKPLUG_MQTT_TLS_CA_CERTS`	No	Path to a CA bundle. Omit to use the system trust store.
`SPARKPLUG_MQTT_TLS_CLIENT_CERT` / `SPARKPLUG_MQTT_TLS_CLIENT_KEY`	No	For mutual TLS.
`SPARKPLUG_GROUP_ID`	No	Restrict discovery/watching to a single Sparkplug Group ID. Omit to subscribe to every group (`spBv1.0/#`).

Running locally

uv sync

export SPARKPLUG_MQTT_HOST=localhost export SPARKPLUG_MQTT_PORT=1883 export SPARKPLUG_HOST_ID=my-mcp-host uv run sparkplugbmcpserver.py

See mcp.json for ready-to-use client configs (stdio and Docker).

Testing against a real broker

This repo's design principles call for testing against a real instance rather than mocks. docker-compose.yml spins up Eclipse Mosquitto (2.x) with an anonymous listener for local testing. Test fixtures use pysparkplug's own EdgeNode/Device classes to act as real simulated PLCs/devices — publishing genuine NBIRTH/DBIRTH/NDATA/DDATA/NDEATH messages and receiving genuine NCMD/DCMD commands over the wire — so coverage is protocol-level, not hand-rolled mocks. Only the "physical" node/device is simulated, since no free real PLC/edge-node hardware exists to test against; the Sparkplug B protocol handling on both sides is real.

docker compose up -d       # start Mosquitto on localhost:1883 (anonymous, local testing only)

uv run pytest -v # tests/conftest.py also starts/stops the stack automatically docker compose down # stop it manually if you started it yourself

License notes

docker-compose.yml and the files under docker/ configure the open-source Eclipse Mosquitto broker (EPL-2.0) for local testing only — they are not part of the MCP server itself.

Sparkplug B

概要

PopNx MCPの3つの柱

できること

インストール

インストールの前に

自分で入力する値

できること

基本チェックi

作者とリポジトリが一致

今もメンテナンスされている

ライセンスがある

エンドポイントが応答する

OAuthでサインイン

ツールの説明に隠れた指示がない

その他のほかのサーバーとの比較i

よくある質問

代わりの候補

Spec Driven Development

Remote Desktop Commander

Apify MCP Server

作者のREADME

Sparkplug B MCP Server

Tools

Why watching is session-based

Supported metric datatypes

Configuration

Running locally

Testing against a real broker

License notes