Record Signal Event

POST /nous/signals/process

Record Signal Event

cURL

curl --request POST \
  --url https://api.sophra.org/api/nous/signals/process \
  --header 'Content-Type: application/json' \
  --data '
"{\r\n    \"signalId\": \"{{signalId}}\",\r\n    \"type\": \"{{processing_type}}\",\r\n    \"status\": \"{{processing_status}}\",\r\n    \"metadata\": {\r\n        \"processingTime\": {{processing_metadata_processingTime}},\r\n        \"processor\": \"{{processing_metadata_processor}}\",\r\n        \"attemptCount\": {{processing_metadata_attemptCount}},\r\n        \"failureReason\": \"{{processing_metadata_failureReason}}\",\r\n        \"processingSteps\": [\r\n            {\r\n                \"step\": \"{{processing_metadata_steps_0_step}}\",\r\n                \"status\": \"{{processing_metadata_steps_0_status}}\",\r\n                \"duration\": {{processing_metadata_steps_0_duration}},\r\n                \"timestamp\": \"{{processing_metadata_steps_0_timestamp}}\"\r\n            },\r\n            {\r\n                \"step\": \"{{processing_metadata_steps_1_step}}\",\r\n                \"status\": \"{{processing_metadata_steps_1_status}}\",\r\n                \"duration\": {{processing_metadata_steps_1_duration}},\r\n                \"timestamp\": \"{{processing_metadata_steps_1_timestamp}}\"\r\n            }\r\n        ],\r\n        \"performance\": {\r\n            \"cpuUsage\": {{processing_metadata_performance_cpuUsage}},\r\n            \"memoryUsage\": {{processing_metadata_performance_memoryUsage}},\r\n            \"latency\": {{processing_metadata_performance_latency}}\r\n        },\r\n        \"context\": {\r\n            \"environment\": \"{{processing_metadata_context_environment}}\",\r\n            \"version\": \"{{processing_metadata_context_version}}\",\r\n            \"batchId\": \"{{processing_metadata_context_batchId}}\"\r\n        }\r\n    }\r\n}"
'

import requests

url = "https://api.sophra.org/api/nous/signals/process"

payload = "{
    \"signalId\": \"{{signalId}}\",
    \"type\": \"{{processing_type}}\",
    \"status\": \"{{processing_status}}\",
    \"metadata\": {
        \"processingTime\": {{processing_metadata_processingTime}},
        \"processor\": \"{{processing_metadata_processor}}\",
        \"attemptCount\": {{processing_metadata_attemptCount}},
        \"failureReason\": \"{{processing_metadata_failureReason}}\",
        \"processingSteps\": [
            {
                \"step\": \"{{processing_metadata_steps_0_step}}\",
                \"status\": \"{{processing_metadata_steps_0_status}}\",
                \"duration\": {{processing_metadata_steps_0_duration}},
                \"timestamp\": \"{{processing_metadata_steps_0_timestamp}}\"
            },
            {
                \"step\": \"{{processing_metadata_steps_1_step}}\",
                \"status\": \"{{processing_metadata_steps_1_status}}\",
                \"duration\": {{processing_metadata_steps_1_duration}},
                \"timestamp\": \"{{processing_metadata_steps_1_timestamp}}\"
            }
        ],
        \"performance\": {
            \"cpuUsage\": {{processing_metadata_performance_cpuUsage}},
            \"memoryUsage\": {{processing_metadata_performance_memoryUsage}},
            \"latency\": {{processing_metadata_performance_latency}}
        },
        \"context\": {
            \"environment\": \"{{processing_metadata_context_environment}}\",
            \"version\": \"{{processing_metadata_context_version}}\",
            \"batchId\": \"{{processing_metadata_context_batchId}}\"
        }
    }
}"
headers = {"Content-Type": "application/json"}

response = requests.post(url, json=payload, headers=headers)

print(response.text)

const options = {
  method: 'POST',
  headers: {'Content-Type': 'application/json'},
  body: JSON.stringify('{\r\n    "signalId": "{{signalId}}",\r\n    "type": "{{processing_type}}",\r\n    "status": "{{processing_status}}",\r\n    "metadata": {\r\n        "processingTime": {{processing_metadata_processingTime}},\r\n        "processor": "{{processing_metadata_processor}}",\r\n        "attemptCount": {{processing_metadata_attemptCount}},\r\n        "failureReason": "{{processing_metadata_failureReason}}",\r\n        "processingSteps": [\r\n            {\r\n                "step": "{{processing_metadata_steps_0_step}}",\r\n                "status": "{{processing_metadata_steps_0_status}}",\r\n                "duration": {{processing_metadata_steps_0_duration}},\r\n                "timestamp": "{{processing_metadata_steps_0_timestamp}}"\r\n            },\r\n            {\r\n                "step": "{{processing_metadata_steps_1_step}}",\r\n                "status": "{{processing_metadata_steps_1_status}}",\r\n                "duration": {{processing_metadata_steps_1_duration}},\r\n                "timestamp": "{{processing_metadata_steps_1_timestamp}}"\r\n            }\r\n        ],\r\n        "performance": {\r\n            "cpuUsage": {{processing_metadata_performance_cpuUsage}},\r\n            "memoryUsage": {{processing_metadata_performance_memoryUsage}},\r\n            "latency": {{processing_metadata_performance_latency}}\r\n        },\r\n        "context": {\r\n            "environment": "{{processing_metadata_context_environment}}",\r\n            "version": "{{processing_metadata_context_version}}",\r\n            "batchId": "{{processing_metadata_context_batchId}}"\r\n        }\r\n    }\r\n}')
};

fetch('https://api.sophra.org/api/nous/signals/process', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api.sophra.org/api/nous/signals/process",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "POST",
  CURLOPT_POSTFIELDS => json_encode('{
    "signalId": "{{signalId}}",
    "type": "{{processing_type}}",
    "status": "{{processing_status}}",
    "metadata": {
        "processingTime": {{processing_metadata_processingTime}},
        "processor": "{{processing_metadata_processor}}",
        "attemptCount": {{processing_metadata_attemptCount}},
        "failureReason": "{{processing_metadata_failureReason}}",
        "processingSteps": [
            {
                "step": "{{processing_metadata_steps_0_step}}",
                "status": "{{processing_metadata_steps_0_status}}",
                "duration": {{processing_metadata_steps_0_duration}},
                "timestamp": "{{processing_metadata_steps_0_timestamp}}"
            },
            {
                "step": "{{processing_metadata_steps_1_step}}",
                "status": "{{processing_metadata_steps_1_status}}",
                "duration": {{processing_metadata_steps_1_duration}},
                "timestamp": "{{processing_metadata_steps_1_timestamp}}"
            }
        ],
        "performance": {
            "cpuUsage": {{processing_metadata_performance_cpuUsage}},
            "memoryUsage": {{processing_metadata_performance_memoryUsage}},
            "latency": {{processing_metadata_performance_latency}}
        },
        "context": {
            "environment": "{{processing_metadata_context_environment}}",
            "version": "{{processing_metadata_context_version}}",
            "batchId": "{{processing_metadata_context_batchId}}"
        }
    }
}'),
  CURLOPT_HTTPHEADER => [
    "Content-Type: application/json"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"strings"
	"net/http"
	"io"
)

func main() {

	url := "https://api.sophra.org/api/nous/signals/process"

	payload := strings.NewReader("\"{\\r\\n    \\\"signalId\\\": \\\"{{signalId}}\\\",\\r\\n    \\\"type\\\": \\\"{{processing_type}}\\\",\\r\\n    \\\"status\\\": \\\"{{processing_status}}\\\",\\r\\n    \\\"metadata\\\": {\\r\\n        \\\"processingTime\\\": {{processing_metadata_processingTime}},\\r\\n        \\\"processor\\\": \\\"{{processing_metadata_processor}}\\\",\\r\\n        \\\"attemptCount\\\": {{processing_metadata_attemptCount}},\\r\\n        \\\"failureReason\\\": \\\"{{processing_metadata_failureReason}}\\\",\\r\\n        \\\"processingSteps\\\": [\\r\\n            {\\r\\n                \\\"step\\\": \\\"{{processing_metadata_steps_0_step}}\\\",\\r\\n                \\\"status\\\": \\\"{{processing_metadata_steps_0_status}}\\\",\\r\\n                \\\"duration\\\": {{processing_metadata_steps_0_duration}},\\r\\n                \\\"timestamp\\\": \\\"{{processing_metadata_steps_0_timestamp}}\\\"\\r\\n            },\\r\\n            {\\r\\n                \\\"step\\\": \\\"{{processing_metadata_steps_1_step}}\\\",\\r\\n                \\\"status\\\": \\\"{{processing_metadata_steps_1_status}}\\\",\\r\\n                \\\"duration\\\": {{processing_metadata_steps_1_duration}},\\r\\n                \\\"timestamp\\\": \\\"{{processing_metadata_steps_1_timestamp}}\\\"\\r\\n            }\\r\\n        ],\\r\\n        \\\"performance\\\": {\\r\\n            \\\"cpuUsage\\\": {{processing_metadata_performance_cpuUsage}},\\r\\n            \\\"memoryUsage\\\": {{processing_metadata_performance_memoryUsage}},\\r\\n            \\\"latency\\\": {{processing_metadata_performance_latency}}\\r\\n        },\\r\\n        \\\"context\\\": {\\r\\n            \\\"environment\\\": \\\"{{processing_metadata_context_environment}}\\\",\\r\\n            \\\"version\\\": \\\"{{processing_metadata_context_version}}\\\",\\r\\n            \\\"batchId\\\": \\\"{{processing_metadata_context_batchId}}\\\"\\r\\n        }\\r\\n    }\\r\\n}\"")

	req, _ := http.NewRequest("POST", url, payload)

	req.Header.Add("Content-Type", "application/json")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.post("https://api.sophra.org/api/nous/signals/process")
  .header("Content-Type", "application/json")
  .body("\"{\\r\\n    \\\"signalId\\\": \\\"{{signalId}}\\\",\\r\\n    \\\"type\\\": \\\"{{processing_type}}\\\",\\r\\n    \\\"status\\\": \\\"{{processing_status}}\\\",\\r\\n    \\\"metadata\\\": {\\r\\n        \\\"processingTime\\\": {{processing_metadata_processingTime}},\\r\\n        \\\"processor\\\": \\\"{{processing_metadata_processor}}\\\",\\r\\n        \\\"attemptCount\\\": {{processing_metadata_attemptCount}},\\r\\n        \\\"failureReason\\\": \\\"{{processing_metadata_failureReason}}\\\",\\r\\n        \\\"processingSteps\\\": [\\r\\n            {\\r\\n                \\\"step\\\": \\\"{{processing_metadata_steps_0_step}}\\\",\\r\\n                \\\"status\\\": \\\"{{processing_metadata_steps_0_status}}\\\",\\r\\n                \\\"duration\\\": {{processing_metadata_steps_0_duration}},\\r\\n                \\\"timestamp\\\": \\\"{{processing_metadata_steps_0_timestamp}}\\\"\\r\\n            },\\r\\n            {\\r\\n                \\\"step\\\": \\\"{{processing_metadata_steps_1_step}}\\\",\\r\\n                \\\"status\\\": \\\"{{processing_metadata_steps_1_status}}\\\",\\r\\n                \\\"duration\\\": {{processing_metadata_steps_1_duration}},\\r\\n                \\\"timestamp\\\": \\\"{{processing_metadata_steps_1_timestamp}}\\\"\\r\\n            }\\r\\n        ],\\r\\n        \\\"performance\\\": {\\r\\n            \\\"cpuUsage\\\": {{processing_metadata_performance_cpuUsage}},\\r\\n            \\\"memoryUsage\\\": {{processing_metadata_performance_memoryUsage}},\\r\\n            \\\"latency\\\": {{processing_metadata_performance_latency}}\\r\\n        },\\r\\n        \\\"context\\\": {\\r\\n            \\\"environment\\\": \\\"{{processing_metadata_context_environment}}\\\",\\r\\n            \\\"version\\\": \\\"{{processing_metadata_context_version}}\\\",\\r\\n            \\\"batchId\\\": \\\"{{processing_metadata_context_batchId}}\\\"\\r\\n        }\\r\\n    }\\r\\n}\"")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://api.sophra.org/api/nous/signals/process")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Post.new(url)
request["Content-Type"] = 'application/json'
request.body = "\"{\\r\\n    \\\"signalId\\\": \\\"{{signalId}}\\\",\\r\\n    \\\"type\\\": \\\"{{processing_type}}\\\",\\r\\n    \\\"status\\\": \\\"{{processing_status}}\\\",\\r\\n    \\\"metadata\\\": {\\r\\n        \\\"processingTime\\\": {{processing_metadata_processingTime}},\\r\\n        \\\"processor\\\": \\\"{{processing_metadata_processor}}\\\",\\r\\n        \\\"attemptCount\\\": {{processing_metadata_attemptCount}},\\r\\n        \\\"failureReason\\\": \\\"{{processing_metadata_failureReason}}\\\",\\r\\n        \\\"processingSteps\\\": [\\r\\n            {\\r\\n                \\\"step\\\": \\\"{{processing_metadata_steps_0_step}}\\\",\\r\\n                \\\"status\\\": \\\"{{processing_metadata_steps_0_status}}\\\",\\r\\n                \\\"duration\\\": {{processing_metadata_steps_0_duration}},\\r\\n                \\\"timestamp\\\": \\\"{{processing_metadata_steps_0_timestamp}}\\\"\\r\\n            },\\r\\n            {\\r\\n                \\\"step\\\": \\\"{{processing_metadata_steps_1_step}}\\\",\\r\\n                \\\"status\\\": \\\"{{processing_metadata_steps_1_status}}\\\",\\r\\n                \\\"duration\\\": {{processing_metadata_steps_1_duration}},\\r\\n                \\\"timestamp\\\": \\\"{{processing_metadata_steps_1_timestamp}}\\\"\\r\\n            }\\r\\n        ],\\r\\n        \\\"performance\\\": {\\r\\n            \\\"cpuUsage\\\": {{processing_metadata_performance_cpuUsage}},\\r\\n            \\\"memoryUsage\\\": {{processing_metadata_performance_memoryUsage}},\\r\\n            \\\"latency\\\": {{processing_metadata_performance_latency}}\\r\\n        },\\r\\n        \\\"context\\\": {\\r\\n            \\\"environment\\\": \\\"{{processing_metadata_context_environment}}\\\",\\r\\n            \\\"version\\\": \\\"{{processing_metadata_context_version}}\\\",\\r\\n            \\\"batchId\\\": \\\"{{processing_metadata_context_batchId}}\\\"\\r\\n        }\\r\\n    }\\r\\n}\""

response = http.request(request)
puts response.read_body

Body

application/json

The body is of type object.

Response

200 - application/json

Successful response