Industrial IoT via MQTT
## Coreflux IoT MCP Server: Industrial IoT Platform The **Coreflux IoT MCP Server** integrates Coreflux industrial IoT platform into Google Antigravity, enabling AI-assisted industrial automation, MQTT messaging, and edge computing for manufacturing and process control. ### Why Coreflux IoT MCP? - **Industrial Focus**: Built for industrial automation use cases - **MQTT Broker**: Integrated MQTT broker for device communication - **Edge Computing**: Process data at the edge before cloud - **Protocol Support**: Modbus, OPC-UA, and industrial protocols - **Real-Time**: Low-latency for time-critical applications ### Key Features #### 1. Asset Management ```python from anthropic import Anthropic client = Anthropic() response = client.messages.create( model="claude-sonnet-4-20250514", max_tokens=1024, messages=[{ "role": "user", "content": "List all connected industrial assets and their operational status" }] ) ``` #### 2. Data Collection ```python # Collect data response = client.messages.create( model="claude-sonnet-4-20250514", max_tokens=1024, messages=[{ "role": "user", "content": "Get real-time sensor data from production line PLCs" }] ) ``` #### 3. Edge Processing ```python # Process at edge response = client.messages.create( model="claude-sonnet-4-20250514", max_tokens=1024, messages=[{ "role": "user", "content": "Deploy edge analytics function to detect anomalies locally" }] ) ``` #### 4. Alerts ```python # Configure alerts response = client.messages.create( model="claude-sonnet-4-20250514", max_tokens=1024, messages=[{ "role": "user", "content": "Set up alert for equipment temperature exceeding safe limits" }] ) ``` ### Configuration ```json { "mcpServers": { "coreflux-iot": { "command": "npx", "args": ["-y", "@anthropic/mcp-server-coreflux"], "env": { "COREFLUX_HOST": "localhost", "COREFLUX_API_KEY": "your-api-key" } } } } ``` ### Use Cases **Manufacturing**: Monitor and control manufacturing processes. **Industrial Automation**: Integrate with PLCs and SCADA systems. **Predictive Maintenance**: Detect equipment issues before failure. **Process Control**: Real-time process monitoring and control. The Coreflux IoT MCP Server brings industrial IoT capabilities into your workflow.
{
"mcpServers": {
"coreflux-iot": {
"mcpServers": {
"coreflux": {
"env": {
"COREFLUX_BROKER": "mqtt://localhost:1883"
},
"args": [
"-y",
"coreflux-mcp"
],
"command": "npx"
}
}
}
}
}