Official DataPulse SDKs

import { DataPulse } from "@datapulse/sdk";

const client = new DataPulse({ apiKey: process.env.DP_API_KEY });

// Execute customer segmentation pipeline
const segments = await client.models.cluster({
  source: "customer_behavior_logs",
  algorithm: "k-means++",
  k: 5
});

console.log(segments.results);

import com.datapulse.sdk.DataPulseClient;
import com.datapulse.sdk.models.PredictionRequest;

DataPulseClient client = DataPulseClient.builder()
    .apiKey("your_api_key_here")
    .build();

PredictionRequest req = PredictionRequest.builder()
    .model("churn_prediction_v3")
    .features("user_activity_stream")
    .build();

var result = client.analytics.predict(req);

package main

import (
    "fmt"
    "github.com/datapulse/sdk-go"
)

func main() {
    client := datapulse.NewClient(
        datapulse.WithAPIKey("your_api_key_here"),
        datapulse.WithRegion("us-east-1"),
    )

    resp, err := client.Predict(context.Background(), &datapulse.PredictOpts{
        Model:   "demand_forecasting",
        Payload: []byte(`{"features": [0.8, 0.9, 0.7]}`),
    })
    if err != nil {
        panic(err)
    }
    fmt.Println(string(resp.Data))
}