Streaming & Messaging AWS Signature Version 4

AWS Kinesis REST API

Real-time streaming data platform for scalable ingestion

AWS Kinesis is a fully managed streaming data service that enables real-time processing of streaming data at scale. Developers use Kinesis to collect, process, and analyze real-time data streams from applications, IoT devices, and operational logs. It provides low-latency data ingestion and processing capabilities with automatic scaling, making it ideal for real-time analytics, log aggregation, and event-driven architectures.

Base URL https://kinesis.us-east-1.amazonaws.com

API Endpoints

Method	Endpoint	Description
POST	`/`	Create a new Kinesis data stream with specified shard count and configuration
POST	`/`	Put a single data record into a Kinesis stream with partition key routing
POST	`/`	Put multiple data records into a stream in a single batch operation
POST	`/`	Get a shard iterator to start reading records from a specific position in a stream
POST	`/`	Retrieve data records from a Kinesis stream using a shard iterator
POST	`/`	List all Kinesis streams in your AWS account with pagination support
POST	`/`	Describe stream details including status, shards, retention period, and encryption
POST	`/`	Delete an existing Kinesis data stream and all associated data
POST	`/`	Update the shard count of a stream to scale capacity up or down
POST	`/`	Modify the data retention period for records in a stream (1-365 days)
POST	`/`	Enable or update server-side encryption using AWS KMS keys
POST	`/`	Add or update tags on a Kinesis stream for organization and billing
POST	`/`	Register a stream consumer for enhanced fan-out with dedicated throughput
POST	`/`	Subscribe to a stream using enhanced fan-out for low-latency consumption
POST	`/`	Split a shard into two child shards to increase stream throughput capacity

Code Examples

curl -X POST https://kinesis.us-east-1.amazonaws.com/ \
  -H 'Content-Type: application/x-amz-json-1.1' \
  -H 'X-Amz-Target: Kinesis_20131202.PutRecord' \
  -H 'Authorization: AWS4-HMAC-SHA256 Credential=AKIAIOSFODNN7EXAMPLE/20231201/us-east-1/kinesis/aws4_request, SignedHeaders=host;x-amz-date;x-amz-target, Signature=...' \
  -d '{
    "StreamName": "my-stream",
    "Data": "SGVsbG8gV29ybGQ=",
    "PartitionKey": "user-12345"
  }'

const { KinesisClient, PutRecordCommand } = require('@aws-sdk/client-kinesis');

const client = new KinesisClient({
  region: 'us-east-1',
  credentials: {
    accessKeyId: 'AKIAIOSFODNN7EXAMPLE',
    secretAccessKey: 'wJalrXUtnFEMI/K7MDENG/bPxRfiCYEXAMPLEKEY'
  }
});

const command = new PutRecordCommand({
  StreamName: 'my-stream',
  Data: Buffer.from(JSON.stringify({ event: 'user_action', userId: '12345' })),
  PartitionKey: 'user-12345'
});

const response = await client.send(command);
console.log('Record written:', response.SequenceNumber);

import boto3
import json

client = boto3.client(
    'kinesis',
    region_name='us-east-1',
    aws_access_key_id='AKIAIOSFODNN7EXAMPLE',
    aws_secret_access_key='wJalrXUtnFEMI/K7MDENG/bPxRfiCYEXAMPLEKEY'
)

data = {'event': 'user_action', 'userId': '12345'}

response = client.put_record(
    StreamName='my-stream',
    Data=json.dumps(data),
    PartitionKey='user-12345'
)

print(f"Record written: {response['SequenceNumber']}")

Use AWS Kinesis from Claude / Cursor / ChatGPT

Get a hosted MCP endpoint for AWS Kinesis. Paste your AWS Kinesis API key, copy back one URL, drop it into Claude Desktop, Cursor, or any AI client that supports remote MCP. Your AI calls AWS Kinesis directly with your credentials — no local install, works on mobile.

kinesis_put_record Send a single event or data record to a Kinesis stream with automatic partition key generation

kinesis_batch_write Write multiple records to Kinesis in a single batch operation for improved throughput

kinesis_read_stream Read and retrieve records from a Kinesis stream starting from a specific sequence number or timestamp

kinesis_create_stream Provision a new Kinesis data stream with specified shard count and retention settings

kinesis_monitor_metrics Retrieve stream metrics including incoming records, throughput, and consumer lag for monitoring

Connect in 60 seconds

Paste your AWS Kinesis key → get an MCP URL → paste into Claude/Cursor. Hosted by IOX, encrypted at rest.

Connect AWS Kinesis to your AI →

AWS Kinesis REST API

API Endpoints

Sponsor this page

Code Examples

Use AWS Kinesis from Claude / Cursor / ChatGPT

Connect in 60 seconds

Related APIs