Amazon Kinesis Analytics
amazonaws · Cloud
Amazon Kinesis Data Analytics is a fully managed service that you can use to process and analyze streaming data using Java, SQL, or Scala. The service enables you to quickly author and run Java, SQL, or Scala code against streaming sources to perform time series analytics, feed real-time dashboards, and create real-time metrics.
Authentication
Sample Requests
Adds an Amazon CloudWatch log stream to monitor application configuration errors.
Hover any highlighted part to learn what it does
| X-Amz-Target | KinesisAnalytics_20180523.AddApplicationCloudWatchLoggingOption |
curl -X POST "https://api.apis.guru/v2/specs/amazonaws.com/kinesisanalyticsv2/2018-05-23/#X-Amz-Target=KinesisAnalytics_20180523.AddApplicationCloudWatchLoggingOption" \ -H "X-Amz-Target: KinesisAnalytics_20180523.AddApplicationCloudWatchLoggingOption"
import requests
headers = {
"X-Amz-Target": "KinesisAnalytics_20180523.AddApplicationCloudWatchLoggingOption"
}
response = requests.post(
"https://api.apis.guru/v2/specs/amazonaws.com/kinesisanalyticsv2/2018-05-23/#X-Amz-Target=KinesisAnalytics_20180523.AddApplicationCloudWatchLoggingOption",
headers=headers,
)
print(response.json())const url = 'https://api.apis.guru/v2/specs/amazonaws.com/kinesisanalyticsv2/2018-05-23/#X-Amz-Target=KinesisAnalytics_20180523.AddApplicationCloudWatchLoggingOption';
const response = await fetch(url, {
method: 'POST',
headers: {
'X-Amz-Target': 'KinesisAnalytics_20180523.AddApplicationCloudWatchLoggingOption'
},
});
const data = await response.json();
console.log(data);package main
import (
"fmt"
"io"
"net/http"
)
func main() {
targetURL := "https://api.apis.guru/v2/specs/amazonaws.com/kinesisanalyticsv2/2018-05-23/#X-Amz-Target=KinesisAnalytics_20180523.AddApplicationCloudWatchLoggingOption"
req, _ := http.NewRequest("POST", targetURL, nil)
req.Header.Set("X-Amz-Target", "KinesisAnalytics_20180523.AddApplicationCloudWatchLoggingOption")
client := &http.Client{}
resp, _ := client.Do(req)
defer resp.Body.Close()
body, _ := io.ReadAll(resp.Body)
fmt.Println(string(body))
}require "net/http"
require "json"
uri = URI("https://api.apis.guru/v2/specs/amazonaws.com/kinesisanalyticsv2/2018-05-23/#X-Amz-Target=KinesisAnalytics_20180523.AddApplicationCloudWatchLoggingOption")
http = Net::HTTP.new(uri.host, uri.port)
http.use_ssl = uri.scheme == "https"
req = Net::HTTP::Post.new(uri)
req["X-Amz-Target"] = "KinesisAnalytics_20180523.AddApplicationCloudWatchLoggingOption"
res = http.request(req)
puts JSON.parse(res.body)<?php
$url = "https://api.apis.guru/v2/specs/amazonaws.com/kinesisanalyticsv2/2018-05-23/#X-Amz-Target=KinesisAnalytics_20180523.AddApplicationCloudWatchLoggingOption";
$opts = ["http" => [
"method" => "POST",
"header" => implode("\r\n", [
"X-Amz-Target: KinesisAnalytics_20180523.AddApplicationCloudWatchLoggingOption"
]),
]];
$ctx = stream_context_create($opts);
$res = file_get_contents($url, false, $ctx);
print_r(json_decode($res, true));Adds a streaming source to your SQL-based Kinesis Data Analytics application. You can add a streaming source when you create an application, or you can use this operation to add a streaming source after you create an application. For more information, see CreateApplication . <p
Hover any highlighted part to learn what it does
| X-Amz-Target | KinesisAnalytics_20180523.AddApplicationInput |
curl -X POST "https://api.apis.guru/v2/specs/amazonaws.com/kinesisanalyticsv2/2018-05-23/#X-Amz-Target=KinesisAnalytics_20180523.AddApplicationInput" \ -H "X-Amz-Target: KinesisAnalytics_20180523.AddApplicationInput"
import requests
headers = {
"X-Amz-Target": "KinesisAnalytics_20180523.AddApplicationInput"
}
response = requests.post(
"https://api.apis.guru/v2/specs/amazonaws.com/kinesisanalyticsv2/2018-05-23/#X-Amz-Target=KinesisAnalytics_20180523.AddApplicationInput",
headers=headers,
)
print(response.json())const url = 'https://api.apis.guru/v2/specs/amazonaws.com/kinesisanalyticsv2/2018-05-23/#X-Amz-Target=KinesisAnalytics_20180523.AddApplicationInput';
const response = await fetch(url, {
method: 'POST',
headers: {
'X-Amz-Target': 'KinesisAnalytics_20180523.AddApplicationInput'
},
});
const data = await response.json();
console.log(data);package main
import (
"fmt"
"io"
"net/http"
)
func main() {
targetURL := "https://api.apis.guru/v2/specs/amazonaws.com/kinesisanalyticsv2/2018-05-23/#X-Amz-Target=KinesisAnalytics_20180523.AddApplicationInput"
req, _ := http.NewRequest("POST", targetURL, nil)
req.Header.Set("X-Amz-Target", "KinesisAnalytics_20180523.AddApplicationInput")
client := &http.Client{}
resp, _ := client.Do(req)
defer resp.Body.Close()
body, _ := io.ReadAll(resp.Body)
fmt.Println(string(body))
}require "net/http"
require "json"
uri = URI("https://api.apis.guru/v2/specs/amazonaws.com/kinesisanalyticsv2/2018-05-23/#X-Amz-Target=KinesisAnalytics_20180523.AddApplicationInput")
http = Net::HTTP.new(uri.host, uri.port)
http.use_ssl = uri.scheme == "https"
req = Net::HTTP::Post.new(uri)
req["X-Amz-Target"] = "KinesisAnalytics_20180523.AddApplicationInput"
res = http.request(req)
puts JSON.parse(res.body)<?php
$url = "https://api.apis.guru/v2/specs/amazonaws.com/kinesisanalyticsv2/2018-05-23/#X-Amz-Target=KinesisAnalytics_20180523.AddApplicationInput";
$opts = ["http" => [
"method" => "POST",
"header" => implode("\r\n", [
"X-Amz-Target: KinesisAnalytics_20180523.AddApplicationInput"
]),
]];
$ctx = stream_context_create($opts);
$res = file_get_contents($url, false, $ctx);
print_r(json_decode($res, true));Adds an InputProcessingConfiguration to a SQL-based Kinesis Data Analytics application. An input processor pre-processes records on the input stream before the application's SQL code executes. Currently, the only input processor available is Amazo
Hover any highlighted part to learn what it does
| X-Amz-Target | KinesisAnalytics_20180523.AddApplicationInputProcessingConfiguration |
curl -X POST "https://api.apis.guru/v2/specs/amazonaws.com/kinesisanalyticsv2/2018-05-23/#X-Amz-Target=KinesisAnalytics_20180523.AddApplicationInputProcessingConfiguration" \ -H "X-Amz-Target: KinesisAnalytics_20180523.AddApplicationInputProcessingConfiguration"
import requests
headers = {
"X-Amz-Target": "KinesisAnalytics_20180523.AddApplicationInputProcessingConfiguration"
}
response = requests.post(
"https://api.apis.guru/v2/specs/amazonaws.com/kinesisanalyticsv2/2018-05-23/#X-Amz-Target=KinesisAnalytics_20180523.AddApplicationInputProcessingConfiguration",
headers=headers,
)
print(response.json())const url = 'https://api.apis.guru/v2/specs/amazonaws.com/kinesisanalyticsv2/2018-05-23/#X-Amz-Target=KinesisAnalytics_20180523.AddApplicationInputProcessingConfiguration';
const response = await fetch(url, {
method: 'POST',
headers: {
'X-Amz-Target': 'KinesisAnalytics_20180523.AddApplicationInputProcessingConfiguration'
},
});
const data = await response.json();
console.log(data);package main
import (
"fmt"
"io"
"net/http"
)
func main() {
targetURL := "https://api.apis.guru/v2/specs/amazonaws.com/kinesisanalyticsv2/2018-05-23/#X-Amz-Target=KinesisAnalytics_20180523.AddApplicationInputProcessingConfiguration"
req, _ := http.NewRequest("POST", targetURL, nil)
req.Header.Set("X-Amz-Target", "KinesisAnalytics_20180523.AddApplicationInputProcessingConfiguration")
client := &http.Client{}
resp, _ := client.Do(req)
defer resp.Body.Close()
body, _ := io.ReadAll(resp.Body)
fmt.Println(string(body))
}require "net/http"
require "json"
uri = URI("https://api.apis.guru/v2/specs/amazonaws.com/kinesisanalyticsv2/2018-05-23/#X-Amz-Target=KinesisAnalytics_20180523.AddApplicationInputProcessingConfiguration")
http = Net::HTTP.new(uri.host, uri.port)
http.use_ssl = uri.scheme == "https"
req = Net::HTTP::Post.new(uri)
req["X-Amz-Target"] = "KinesisAnalytics_20180523.AddApplicationInputProcessingConfiguration"
res = http.request(req)
puts JSON.parse(res.body)<?php
$url = "https://api.apis.guru/v2/specs/amazonaws.com/kinesisanalyticsv2/2018-05-23/#X-Amz-Target=KinesisAnalytics_20180523.AddApplicationInputProcessingConfiguration";
$opts = ["http" => [
"method" => "POST",
"header" => implode("\r\n", [
"X-Amz-Target: KinesisAnalytics_20180523.AddApplicationInputProcessingConfiguration"
]),
]];
$ctx = stream_context_create($opts);
$res = file_get_contents($url, false, $ctx);
print_r(json_decode($res, true));Postman Setup Guide
- See official documentation for authentication and setup.
What can you build with Amazon Kinesis Analytics?
Amazon Kinesis Analytics is a Cloud API. Developers commonly use cloud APIs for:
- provisioning and managing cloud infrastructure
- automating deployments and container orchestration
- monitoring uptime and performance metrics
- managing storage buckets and databases
- setting up auto-scaling and load balancing
No authentication required. This API is open — no signup or key needed. Ideal for quick prototypes and public-facing features. Amazon Kinesis Analytics is free to use, making it a low-risk choice to experiment with.
New to APIs? Read our beginner's guide · Learn about API keys · What is REST?