Sparkplug B

Name: Sparkplug B
Author: nagarjunr

โดย nagarjunrรุ่น 0.1.0i★ 0iรันบนเครื่อง

ชื่อใน registryio.github.nagarjunr/sparkplug-b

ติดตั้ง

ภาพรวม

คำอธิบายจากผู้ทำ (ภาษาอังกฤษตามต้นฉบับ)

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

สามเสาของ PopNx MCP

สามเรื่องนี้ไม่รวมเป็นคะแนนเดียว เพราะความเห็น การวัด และความนิยม เป็นคนละเรื่องกัน

เสียงผู้ใช้iยังไม่มีรีวิวรีวิวเปิดพร้อมระบบบัญชีในขั้นถัดไป
ผลตรวจเบื้องต้นของเราiผ่าน 2 จาก 2 ข้อตรวจจากข้อมูลที่เปิดอยู่ ยังไม่ได้สแกนโค้ด
การใช้งานiยังใหม่มาก↓ 14/สัปดาห์ · ★ 0

ใช้ทำอะไรได้

ตัวนี้ยังไม่ได้เรียบเรียงเป็นภาษาไทย ด้านล่างคือข้อเท็จจริงที่เราอ่านจาก registry

การเชื่อมต่อ: รันบนเครื่อง
ช่องทาง (transport): stdio
หมวด: อื่น ๆ
ต้องใส่ค่าเหล่านี้: SPARKPLUG_MQTT_HOST, SPARKPLUG_HOST_ID, SPARKPLUG_MQTT_PASSWORD

ติดตั้ง

เลือกโปรแกรม AI ที่คุณใช้ แล้วคัดลอกค่าตั้งไปวาง

ก่อนติดตั้ง

ผลตรวจเบื้องต้น: ผ่าน 2 จาก 2 ข้อ
รันในเครื่องคุณด้วยสิทธิ์ของผู้ใช้คุณ (ไฟล์ อินเทอร์เน็ต แอปต่าง ๆ)
ค่าที่คุณต้องใส่เอง: SPARKPLUG_MQTT_HOST, SPARKPLUG_HOST_ID, SPARKPLUG_MQTT_PORT, SPARKPLUG_MQTT_USERNAME, SPARKPLUG_MQTT_PASSWORD, SPARKPLUG_MQTT_USE_TLS, SPARKPLUG_GROUP_ID

ค่าที่ติดป้ายความลับคือกุญแจของบัญชีคุณ อย่าส่งให้ใคร และอย่าวางในแชต

ต้องเตรียมก่อน

PyPIติดตั้ง uv ของ Python (มีคำสั่ง 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": "ใส่ค่าของคุณ",
        "SPARKPLUG_HOST_ID": "ใส่ค่าของคุณ",
        "SPARKPLUG_MQTT_PORT": "ใส่ค่าของคุณ",
        "SPARKPLUG_MQTT_USERNAME": "ใส่ค่าของคุณ",
        "SPARKPLUG_MQTT_PASSWORD": "ใส่ค่าของคุณ",
        "SPARKPLUG_MQTT_USE_TLS": "ใส่ค่าของคุณ",
        "SPARKPLUG_GROUP_ID": "ใส่ค่าของคุณ"
      }
    }
  }
}

พิมพ์คำสั่งนี้ใน Terminal

claude mcp add sparkplug-b --env SPARKPLUG_MQTT_HOST='ใส่ค่าของคุณ' --env SPARKPLUG_HOST_ID='ใส่ค่าของคุณ' --env SPARKPLUG_MQTT_PORT='ใส่ค่าของคุณ' --env SPARKPLUG_MQTT_USERNAME='ใส่ค่าของคุณ' --env SPARKPLUG_MQTT_PASSWORD='ใส่ค่าของคุณ' --env SPARKPLUG_MQTT_USE_TLS='ใส่ค่าของคุณ' --env SPARKPLUG_GROUP_ID='ใส่ค่าของคุณ' -- 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": "ใส่ค่าของคุณ",
        "SPARKPLUG_HOST_ID": "ใส่ค่าของคุณ",
        "SPARKPLUG_MQTT_PORT": "ใส่ค่าของคุณ",
        "SPARKPLUG_MQTT_USERNAME": "ใส่ค่าของคุณ",
        "SPARKPLUG_MQTT_PASSWORD": "ใส่ค่าของคุณ",
        "SPARKPLUG_MQTT_USE_TLS": "ใส่ค่าของคุณ",
        "SPARKPLUG_GROUP_ID": "ใส่ค่าของคุณ"
      }
    }
  }
}

เบราว์เซอร์จะถามก่อนเปิดแอป จากนั้นแอปแสดงค่าตั้งให้ตรวจแล้วกดยืนยัน ช่อง key เว้นว่างไว้ให้คุณใส่เอง

เปิดใน VS Code

หรือคัดลอกค่าตั้งเอง

วางในไฟล์ .vscode/mcp.json ของโปรเจกต์

{
  "servers": {
    "sparkplug-b": {
      "type": "stdio",
      "command": "uvx",
      "args": [
        "sparkplug-b-mcp-server"
      ],
      "env": {
        "SPARKPLUG_MQTT_HOST": "ใส่ค่าของคุณ",
        "SPARKPLUG_HOST_ID": "ใส่ค่าของคุณ",
        "SPARKPLUG_MQTT_PORT": "ใส่ค่าของคุณ",
        "SPARKPLUG_MQTT_USERNAME": "ใส่ค่าของคุณ",
        "SPARKPLUG_MQTT_PASSWORD": "ใส่ค่าของคุณ",
        "SPARKPLUG_MQTT_USE_TLS": "ใส่ค่าของคุณ",
        "SPARKPLUG_GROUP_ID": "ใส่ค่าของคุณ"
      }
    }
  }
}

ตัวนี้รันในเครื่องคุณ แต่ ChatGPT ต่อได้เฉพาะ server บนอินเทอร์เน็ต ลองเลือกแอปอื่น

ตัวเลือกเก็บในคุกกี้บนเครื่องนี้ ไม่ต้องมีบัญชี

ค่าที่ต้องใส่เอง

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

ค่าตั้งนี้สร้างจากข้อมูลใน registry ของผู้ทำ ถ้าไม่ตรงกับ README ให้เชื่อ README

ใช้กับโปรแกรมไหนได้

ดูจากแบบการต่อของ server ตัวนี้ และเอกสารของผู้ทำโปรแกรมแต่ละตัว ตรวจเมื่อ 10 พ.ย. 2569

ติดตั้งบนเครื่องได้ใน

Claude Goose LM Studio Msty Studio Cherry Studio Cursor VS Code + GitHub Copilot Visual Studio Windsurf (Devin Desktop)Zed Kiro Cline Continue JetBrains AI Assistant Claude Code Codex CLI Gemini CLI OpenCode nodecode Warp LibreChat Raycast

ดูโปรแกรมทั้งหมดพร้อมข้อดีข้อเสีย →

คู่มือที่เกี่ยวข้อง

เรื่องที่ 8เช็ก 5 ข้อก่อนติดตั้ง MCP ไม่ให้ข้อมูลรั่วใช้เวลาราว 2 นาทีต่อตัว ดูจากหน้าของตัวนั้นบนเว็บเรา และหน้าขออนุญาตของโปรแกรม AI ก่อนกดยอมอ่าน 4 นาที

ทำอะไรได้บ้าง

รันในเครื่องคุณ รายการเครื่องมือจะขึ้นในแอป AI หลังติดตั้ง

ผลตรวจเบื้องต้นi

เราตรวจจากข้อมูลที่ใครก็เปิดดูได้ ยังไม่ได้อ่านโค้ด ข้อที่ไม่เกี่ยวกับตัวนี้ไม่นับในตัวหาร · ตรวจเมื่อ 11 พ.ย. 2569

✓ ผ่าน
ตัวตนผู้ทำตรงกับ repo
ชื่อใน registry ยืนยันด้วยบัญชี GitHub nagarjunr ซึ่งเป็นเจ้าของ repo
✓ ผ่าน
ยังมีคนดูแล
มีการแก้โค้ดล่าสุด 10 วันที่ผ่านมา
… ยังไม่ตรวจ
มีสัญญาอนุญาต (license)
ยังไม่ได้อ่านข้อมูล repo จาก GitHub
– ไม่เกี่ยว
endpoint ตอบ
ตัวนี้รันบนเครื่องคุณ ไม่มี endpoint บนอินเทอร์เน็ต
– ไม่เกี่ยว
ล็อกอินแบบ OAuth
ตัวนี้รันบนเครื่อง ใช้ค่าที่ตั้งในเครื่องแทน
… ยังไม่ตรวจ
คำอธิบายเครื่องมือไม่มีคำสั่งแอบแฝง
รันในเครื่องคุณ เราอ่านรายการเครื่องมือได้เฉพาะตัวที่มี endpoint บนอินเทอร์เน็ต

เทียบกับตัวอื่นในหมวด อื่น ๆi

ดาวมากกว่า 0% ของอีก 19103 ตัวในหมวดนี้
ส่งรุ่นใหม่เข้า registry ล่าสุดกว่า 18% ของอีก 19103 ตัวในหมวดนี้
ผลตรวจเบื้องต้นดีกว่าหรือเท่ากับ 100% ของอีก 19103 ตัวในหมวดนี้

เทียบกับทุก server ที่ยังใช้งานในหมวดนี้ทั้งทะเบียน ดาวนับเฉพาะเมื่อผู้ลงทะเบียนเป็นเจ้าของ repo

คำถามที่พบบ่อย

Sparkplug B ปลอดภัยไหม?

จากการตรวจเบื้องต้นของเรา ผ่าน 2 จาก 2 ข้อที่ตรวจได้ เรายังไม่ได้อ่านโค้ด ก่อนใส่กุญแจหรือ token ให้ดูว่า server ขอสิทธิ์อะไร และเลือกกุญแจที่ทำได้เท่าที่จำเป็น

ต้องใช้กุญแจหรือรหัสอะไรบ้าง?

ต้องใส่ค่าเหล่านี้: SPARKPLUG_MQTT_HOST, SPARKPLUG_HOST_ID, SPARKPLUG_MQTT_PASSWORD

ตัวนี้รันบนเครื่องหรือบนคลาวด์?

รันบนเครื่องของคุณ โปรแกรม AI จะเปิด server ขึ้นมาเองเมื่อใช้ ข้อมูลไม่ต้องผ่านเซิร์ฟเวอร์ของผู้ทำ (ยกเว้นตัวที่ไปเรียกบริการออนไลน์ต่อ)

ยังมีคนดูแลอยู่ไหม?

repo บน GitHub มีการแก้โค้ดล่าสุด 10 วันที่ผ่านมา และส่งรุ่นล่าสุด (0.1.0) เข้า registry 3 เดือนที่ผ่านมา

ใช้กับโปรแกรมไหนได้บ้าง?

โปรแกรมที่รองรับ MCP เช่น Claude Desktop, Claude Code, Cursor และ VS Code ตัวนี้ต้องมี Python (uv) ในเครื่องด้วย

มีตัวไหนใช้แทนได้บ้าง?

ในหมวดเดียวกันมี World Monitor, Claude Flow, Tldraw

ตัวที่ใช้แทนได้

server หมวดเดียวกันจากผู้ทำคนอื่น เรียงตามดาว

อ่านการ์ด:↓ ดาวน์โหลดต่อสัปดาห์i★ ดาว GitHubiสามเสา: รีวิว · ผลตรวจ · การใช้งานiอัปเดต = วันที่ส่งรุ่นล่าสุดเข้า registryi

World Monitor

Real-time global intelligence on conflict, markets, energy, trade, shipping and cyber. 102 tools.

โดย koala73ใช้กันมาก★ 90.4Kอัปเดต 6 วันที่ผ่านมา

รันบนคลาวด์✓ worldmonitor.app

ติดตั้ง

Claude Flow

AI orchestration with hive-mind swarms, neural networks, and 87 MCP tools for enterprise dev.

โดย ruvnetใช้กันมาก↓ 13.5K/สัปดาห์★ 81.4Kอัปเดต 14 เดือนที่ผ่านมา

รันบนเครื่อง

ติดตั้ง

Tldraw

Draw and visually collaborate with your agents on tldraw's canvas.

โดย tldrawใช้กันมาก★ 51.4Kอัปเดต 8 เดือนที่ผ่านมา

รันบนคลาวด์

ติดตั้ง

README จากผู้ทำ

เปิดอ่าน README

ส่วนนี้คัดจาก repo ของผู้ทำตามต้นฉบับ 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

ใช้ทำอะไรได้

ติดตั้ง

ก่อนติดตั้ง

ค่าที่ต้องใส่เอง

ใช้กับโปรแกรมไหนได้

คู่มือที่เกี่ยวข้อง

ทำอะไรได้บ้าง

ผลตรวจเบื้องต้นi

ตัวตนผู้ทำตรงกับ repo

ยังมีคนดูแล

มีสัญญาอนุญาต (license)

endpoint ตอบ

ล็อกอินแบบ OAuth

คำอธิบายเครื่องมือไม่มีคำสั่งแอบแฝง

เทียบกับตัวอื่นในหมวด อื่น ๆi

คำถามที่พบบ่อย

ตัวที่ใช้แทนได้

World Monitor

Claude Flow

Tldraw

README จากผู้ทำ

Sparkplug B MCP Server

Tools

Why watching is session-based

Supported metric datatypes

Configuration

Running locally

Testing against a real broker

License notes