/spark/commands
1 min
POST
https://app.amberflo.io/spark/commands
Body Parameters
- bodycom.amberflo.spark.pipeline.SparkCommand.in[]
- objectcom.amberflo.spark.pipeline.commands.experimental.CreateAnalyticsSnapshotCommand.in
- typestringDefaultanalytics_snapshot
- accountIdstring
- meterApiNamestring
- deduplicationIdstring
- windowStartTimeInSecondsstring
- windowEndTimeInSecondsstring
- objectcom.amberflo.spark.pipeline.commands.experimental.MauHistoryBootstrapCommand.in
- typestringDefaultmau_bootstrap
- accountIdstring
- meterApiNamestring
- deduplicationIdstring
- weekToRunInSecondsinteger<int64>
- objectcom.amberflo.spark.pipeline.commands.experimental.MergeHourlyIngestEventsCommand.in
- typestringDefaultmerge_hourly_ingest_events
- accountIdstring
- meterApiNamestring
- deduplicationIdstring
- hourToRunInSecondsinteger<int64>
- meterApiNamesstring[]
- objectcom.amberflo.spark.pipeline.commands.experimental.ProcessedHourlyEventsCommand.in
- typestringDefaultprocessed_hourly_events
- accountIdstring
- meterApiNamestring
- deduplicationIdstring
- hourToRunInSecondsinteger<int64>
- objectcom.amberflo.spark.pipeline.commands.SparkPiCommand.in
- typestringDefaultspark_pi
- accountIdstring
- meterApiNamestring
- deduplicationIdstring
- sliceCountinteger<int32>
- objectcom.amberflo.spark.pipeline.commands.experimental.UpdateHistoryCommand.in
- typestringDefaultupdate_history
- accountIdstring
- meterApiNamestring
- deduplicationIdstring
- hourToRunInSecondsinteger<int64>
Responses
200
- com.amberflo.spark.pipeline.SparkCommand.out[]
- objectcom.amberflo.spark.pipeline.commands.experimental.CreateAnalyticsSnapshotCommand.out
- typestringDefaultanalytics_snapshot
- accountIdstring
- meterApiNamestring
- deduplicationIdstring
- windowStartTimeInSecondsstring
- windowEndTimeInSecondsstring
- objectcom.amberflo.spark.pipeline.commands.experimental.MauHistoryBootstrapCommand.out
- typestringDefaultmau_bootstrap
- accountIdstring
- meterApiNamestring
- deduplicationIdstring
- weekToRunInSecondsinteger<int64>
- objectcom.amberflo.spark.pipeline.commands.experimental.MergeHourlyIngestEventsCommand.out
- typestringDefaultmerge_hourly_ingest_events
- accountIdstring
- meterApiNamestring
- deduplicationIdstring
- hourToRunInSecondsinteger<int64>
- meterApiNamesstring[]
- objectcom.amberflo.spark.pipeline.commands.experimental.ProcessedHourlyEventsCommand.out
- typestringDefaultprocessed_hourly_events
- accountIdstring
- meterApiNamestring
- deduplicationIdstring
- hourToRunInSecondsinteger<int64>
- objectcom.amberflo.spark.pipeline.commands.SparkPiCommand.out
- typestringDefaultspark_pi
- accountIdstring
- meterApiNamestring
- deduplicationIdstring
- sliceCountinteger<int32>
- objectcom.amberflo.spark.pipeline.commands.experimental.UpdateHistoryCommand.out
- typestringDefaultupdate_history
- accountIdstring
- meterApiNamestring
- deduplicationIdstring
- hourToRunInSecondsinteger<int64>
curl
curl --request POST \
--url https://app.amberflo.io/spark/commands \
--header 'accept: application/json' \
--header 'content-type: application/json' \
--data '[
{
"type": "analytics_snapshot"
}
]'javascript
var myHeaders = new Headers();
myHeaders.append("accept", "application/json");
myHeaders.append("content-type", "application/json");
var raw = JSON.stringify([
{
"type": "analytics_snapshot"
}
]);
var requestOptions = {
method: 'POST',
headers: myHeaders,
body: raw,
redirect: 'follow'
};
fetch("https://app.amberflo.io/spark/commands", requestOptions)
.then(response => response.text())
.then(result => console.log(result))
.catch(error => console.log('error', error));ruby
require "uri"
require "json"
require "net/http"
url = URI("https://app.amberflo.io/spark/commands")
https = Net::HTTP.new(url.host, url.port)
https.use_ssl = true
request = Net::HTTP::Post.new(url)
request["accept"] = "application/json"
request["content-type"] = "application/json"
request.body = JSON.dump([
{
"type": "analytics_snapshot"
}
])
response = https.request(request)
puts response.read_body
python
import requests
import json
url = "https://app.amberflo.io/spark/commands"
payload = json.dumps([
{
"type": "analytics_snapshot"
}
])
headers = {
'accept': 'application/json',
'content-type': 'application/json'
}
response = requests.request("POST", url, headers=headers, data=payload)
print(response.text)
200
// Successful request
[
""
]