AWS Amazon Kinesis Analytics
Browse all Amazonaws APIs★ Only Publicly Available OpenAPI DocumentAnalyticsData Pipelineshmac20 EndpointsREST
For Agents
Run continuous SQL queries over streaming data from Kinesis Data Streams or Firehose without managing the underlying compute.
Use for: I need to set up a streaming SQL job over a Kinesis stream, Get the current state of a Kinesis Analytics application, List all streaming SQL applications in a region, Discover the schema of an input stream
Not supported: Does not handle Apache Flink applications, raw stream produce or consume traffic, or batch ETL — use for v1 SQL-based streaming application management only.
Jentic publishes the only available OpenAPI specification for Amazon Kinesis Analytics, keeping it validated and agent-ready. Kinesis Analytics is the v1 SQL-based service for running continuous queries over streaming data from Kinesis Data Streams or Kinesis Firehose. Its 20-endpoint API covers application creation, input and output configuration, reference data sources, CloudWatch logging options, schema discovery, and lifecycle controls to start and stop applications. The service is suited to teams running SQL transformations on event streams without standing up Spark or Flink clusters themselves.
Install Jentic One Beta
Connect the Amazon Kinesis Analytics to your agent
Jentic One is a self-hosted execution layer for AI agents. It lets your agent call the Amazon Kinesis Analytics, or any other public or private API you need. You set the rules, the agent never sees your credentials, and every call is logged.
Two steps, two machines. Install the instance in a safe environment, then register your agent from wherever it runs.
1
Step 1: Jentic One Host machine
# On the machine that will host your Jentic One instance:
curl -fsSL https://raw.githubusercontent.com/jentic/jentic-one/main/tools/install.sh | sh2
Step 2: Agent machine
# On the machine where your agent runs (keep this separate from the instance):
curl -fsSL https://raw.githubusercontent.com/jentic/jentic-one/main/tools/install.sh | sh
jentic register # connects your agent to your Jentic One instanceJentic One is in public beta. The setup above keeps your agent separate from the instance, which is what you want before using real credentials: an agent running as the same OS user as Jentic One can read its stored keys directly. Just evaluating? A single local install is fine to start. See the secure deployment guide for the tiers.
Capabilities
What an agent can do with Amazon Kinesis Analytics API.
Create SQL streaming applications via CreateApplication
Configure inputs from Kinesis Data Streams or Firehose with AddApplicationInput
Add reference data from S3 with AddApplicationReferenceDataSource
Stream output to Lambda or Firehose via AddApplicationOutput
Discover input schemas automatically with DiscoverInputSchema
Start and stop applications to control billing and throughput
Configure CloudWatch logging for SQL diagnostics
Use Cases
Patterns agents use Amazon Kinesis Analytics API for, with concrete tasks.
★ Real-Time Fraud Signals
Run continuous SQL queries over a transaction event stream to flag anomalous patterns in seconds. The Kinesis Analytics application reads from a Kinesis Data Stream, joins reference data from S3, and emits alerts to a downstream Firehose or Lambda output. Teams use this to detect velocity violations, dollar-amount thresholds, and other rule-based anomalies without writing Flink jobs.
Create application 'fraud-rules' with SQL that flags transactions where amount > 10000 from input stream txn-events
Stream Aggregation for Dashboards
Aggregate a high-volume event stream into per-minute metrics for live dashboards. Kinesis Analytics supports tumbling and sliding windows in SQL, which makes it straightforward to compute count, sum, and average over time windows and write the results into a destination stream that powers a near-real-time dashboard or alerting system.
Create an application that emits per-minute counts of input stream click-events to output stream click-counts using a tumbling window
Schema Discovery for Pipelines
Bootstrap a new streaming pipeline by discovering the schema of an input stream automatically. The DiscoverInputSchema operation samples records from a Kinesis stream and infers column names, types, and record format, which speeds up onboarding new event sources and reduces manual SQL configuration mistakes.
Run DiscoverInputSchema against stream txn-events with role arn:aws:iam::123:role/kinesis-analytics-discovery and return the inferred columns
AI Agent Streaming Pipeline Operations
AI agents call Kinesis Analytics through Jentic to create new applications when teams onboard event sources, start and stop applications based on cost guards, and inspect schemas before configuring downstream consumers. Through Jentic, the agent searches by intent, loads the operation schema, and executes with credentials stored in the vault. SigV4 signing happens inside Jentic so the agent runtime stays slim.
Search Jentic for 'start kinesis analytics application', load the StartApplication schema, and execute against application 'fraud-rules'
Key Endpoints
20 endpoints — jentic publishes the only available openapi specification for amazon kinesis analytics, keeping it validated and agent-ready.
METHOD
PATH
DESCRIPTION
POST
/#X-Amz-Target=KinesisAnalytics_20150814.CreateApplication
Create a streaming SQL application
POST
/#X-Amz-Target=KinesisAnalytics_20150814.StartApplication
Start an application
POST
/#X-Amz-Target=KinesisAnalytics_20150814.StopApplication
Stop a running application
POST
/#X-Amz-Target=KinesisAnalytics_20150814.AddApplicationInput
Configure an input stream
POST
/#X-Amz-Target=KinesisAnalytics_20150814.AddApplicationOutput
Configure an output destination
POST
/#X-Amz-Target=KinesisAnalytics_20150814.DiscoverInputSchema
Auto-discover the schema of a stream
POST
/#X-Amz-Target=KinesisAnalytics_20150814.CreateApplication
Create a streaming SQL application
POST
/#X-Amz-Target=KinesisAnalytics_20150814.StartApplication
Start an application
POST
/#X-Amz-Target=KinesisAnalytics_20150814.StopApplication
Stop a running application
POST
/#X-Amz-Target=KinesisAnalytics_20150814.AddApplicationInput
Configure an input stream
POST
/#X-Amz-Target=KinesisAnalytics_20150814.AddApplicationOutput
Configure an output destination
POST
/#X-Amz-Target=KinesisAnalytics_20150814.DiscoverInputSchema
Auto-discover the schema of a stream
Why Jentic?
Three things that make agents converge on Jentic-routed access.
Credential isolation
AWS access keys for Kinesis Analytics are stored encrypted in the Jentic vault. Jentic performs SigV4 signing at execution time, so raw AWS secrets never enter the agent's context.
Intent-based discovery
Agents search Jentic by intent such as 'create streaming sql application' or 'start kinesis analytics application' and Jentic returns the matching operation with its input schema, so the agent calls the right endpoint without parsing AWS docs.
Time to first call
Direct integration: 1-2 days to set up SigV4, IAM, and application lifecycle handling. Through Jentic: under 1 hour — search, load the schema, execute.
Related APIs
Alternatives and complements available in the Jentic catalogue.
FAQs
Specific to using Amazon Kinesis Analytics API through Jentic.
Why is there no official OpenAPI spec for Amazon Kinesis Analytics?
AWS does not publish an OpenAPI specification. Jentic generates and maintains this spec so that AI agents and developers can call Amazon Kinesis Analytics via structured tooling. It is validated against the live API and kept up to date. Get started at https://app.jentic.com/sign-up.
What authentication does the Kinesis Analytics API use?
Kinesis Analytics uses AWS Signature Version 4 (SigV4) HMAC request signing. Each call must be signed with an access key, secret key, and optional session token scoped to the kinesisanalytics IAM service. Through Jentic, these credentials sit in the encrypted vault and signing happens at execution time.
Can I run streaming SQL with the Kinesis Analytics API?
Yes. CreateApplication accepts an ApplicationCode field containing your SQL, plus input and output configurations that wire the application to Kinesis Data Streams, Firehose, or Lambda. The service handles parsing, scheduling, and scaling automatically.
How do I start a streaming application through Jentic?
Search Jentic for 'start kinesis analytics application', load the StartApplication schema, submit the application name and an InputConfiguration with the InputId and starting position, and Jentic will sign and execute the call.
What are the rate limits for the Kinesis Analytics API?
Per-region quotas apply, including a default cap on applications per account and TPS limits on control plane operations such as CreateApplication and DescribeApplication. Check the Kinesis Analytics service quotas in the AWS console for current values.
Can the Kinesis Analytics API discover an input schema automatically?
Yes. DiscoverInputSchema samples records from a Kinesis Data Stream or Firehose using a supplied IAM role and returns the inferred record format and column list. Use this before configuring AddApplicationInput so the schema is correct on the first attempt.
How does Kinesis Analytics differ from Kinesis Data Analytics for Apache Flink?
This API covers the v1 SQL-based service. AWS also offers a separate Kinesis Data Analytics for Apache Flink service for Java, Scala, and Python applications. Pick the SQL service for simple windowed transforms; pick Flink for stateful processing and custom code.
GET STARTED