Experience Fetch in Action

const fetch = require('@scadadog/fetch-sdk');

const client = new fetch.Client({
  host: 'localhost',
  port: 8080
});

// Subscribe to MQTT data
client.mqtt.subscribe('sensors/+/temperature', {
  transform: 'temperature_celsius',
  filter: 'value > 25'
});

client.on('data', (message) => {
  console.log('Temperature:', message.value);
});

import fetch_sdk

client = fetch_sdk.Client('localhost:8080')

# Configure Modbus TCP device
device = client.modbus.add_device({
    'host': '192.168.1.100',
    'port': 502,
    'unit_id': 1
})

# Poll holding registers
registers = device.read_holding_registers(
    address=0, 
    count=10,
    interval=1000  # 1 second
)

for value in registers:
    print(f"Register {value.address}: {value.data}")

package main

import (
    "github.com/scadadog/fetch-go"
)

func main() {
    client := fetch.NewClient("localhost:8080")
    
    // Connect to OPC UA server
    opcua := client.OPCUA().Connect(&fetch.OPCUAConfig{
        Endpoint: "opc.tcp://192.168.1.200:4840",
        Security: fetch.SecurityModeNone,
    })
    
    // Subscribe to node changes
    opcua.Subscribe("ns=2;i=1001", func(value interface{}) {
        fmt.Printf("Node value changed: %v\n", value)
    })
}

using ScadaDog.Fetch.SDK;

var client = new FetchClient("localhost:8080");

// Create transformation pipeline
var pipeline = client.Transformations.Create(new Pipeline {
    Name = "temperature_processing",
    Steps = new[] {
        new JsonPathStep("$.sensors[*].temperature"),
        new FilterStep("value > 20 && value < 80"),
        new MapStep("celsius_to_fahrenheit"),
        new RouteStep("analytics/temperature")
    }
});

await pipeline.StartAsync();