Sending device data to an external system

Let's create a flow that sends your device data to an external system through MQTT. Rather than creating multiple endpoints separately, we can accomplish this in one single request.

Need HTTP POST instead of MQTT? Use the Webhook node.

Creating a complete flow with integrated MQTT node

The simplest approach is to define both your data sources and MQTT output endpoint directly in your flow creation request. To do it, send a request to the following endpoint:

flowCreate

post

https://api.eu.navixy.com/v2https://api.us.navixy.com/v2

/iot/logic/flow/create

Create a new data processing flow with nodes and connections. Flows define how data moves from devices through transformation stages to output destinations. Each flow requires at least one Data Source node and one Output Endpoint node. You can create flows with nodes and edges in a single request or add nodes later using the endpoint management API.

Authorizations

api_key

AuthorizationstringRequired

Enter an API key with the "NVX: " prefix, e.g. "NVX 123456abcdefg"

Body

application/json

Responses

200

Successful creation response

application/json

successbooleanRead-onlyOptional

true if request finished successfully

Example: true

idintegerRead-onlyOptional

ID of the created entity

Example: 1723

default

Error response object

application/json

post

/iot/logic/flow/create

HTTPcURLJavaScriptPython

POST /v2/iot/logic/flow/create HTTP/1.1
Host: api.eu.navixy.com
Authorization: YOUR_API_KEY
Content-Type: application/json
Accept: */*
Content-Length: 240

{
  "flow": {
    "title": "Super flow",
    "enabled": true,
    "nodes": [
      {
        "id": 1,
        "type": "data_source",
        "data": {
          "title": "Standard Data Source",
          "source_ids": [
            123458,
            123459
          ]
        },
        "view": {
          "position": {
            "x": 25,
            "y": 25
          }
        }
      }
    ],
    "edges": [
      {
        "from": 1,
        "to": 2,
        "type": "simple_edge"
      }
    ]
  }
}

{
  "success": true,
  "id": 1723
}

Request example

curl -X POST "https://api.{region}.navixy.com/v2/iot/logic/flow/create" \
  -H "Content-Type: application/json" \
  -H "Authorization: NVX your_token_here" \
  -d '{
  "flow": {
    "title": "Fleet data to external system",
    "enabled": true,
    "nodes": [
      {
        "id": 1,
        "type": "data_source",
        "enabled": true,
        "data": {
          "title": "Fleet vehicles",            // Title must be in the data object
          "sources": [12345, 12346, 12347]      // Your actual vehicle IDs
        },
        "view": {
          "position": { "x": 50, "y": 50 }
        }
      },
      {
        "id": 2,
        "type": "output_endpoint",
        "enabled": true,
        "data": {
          "title": "External MQTT System",       // Title must be located in the data object
          "output_endpoint_type": "output_mqtt_client",  // Defines this as an MQTT output
          "output_endpoint_id": 45678,           // Required ID (can be any unique number)
          "properties": {
            "protocol": "Navixy Generic Protocol (NGP)", // Navixy Generic Protocol
            "domain": "mqtt.mycompany.com",      // Your MQTT broker address
            "port": 1883,                        // Standard MQTT port
            "client_id": "navixy-integration",   // Identifier for this client
            "qos": 1,                            // Quality of Service level
            "topics": ["fleet/vehicles/data"],   // Topics to publish to
            "version": "5.0",                    // MQTT protocol version
            "use_ssl": true,                     // Secure connection
            "mqtt_auth": true,                   // Authentication required
            "user_name": "mqtt_username",        // Your MQTT credentials
            "user_password": "mqtt_password"
          }
        },
        "view": {
          "position": { "x": 250, "y": 50 }
        }
      }
    ],
    "edges": [
      {
        "from": 1,  // Connect the data source node (id: 1)
        "to": 2     // to the MQTT output node (id: 2)
      }
    ]
  }
}'

The response will include the flow ID:

{
  "success": true,
  "id": 1234
}

Congratulations!

You've now set up a flow that creates a complete end-to-end data pipeline in a single API call. This flow:

• Connects to multiple vehicles in your fleet through a data source endpoint

• Sends the device data to your external MQTT system

• Uses your custom MQTT broker settings for secure data transfer