Yandex Cloud
Search
Discuss with expertTry it for free
  • Customer Stories
  • Documentation
  • Blog
  • All Services
    • Cloud Interconnect
    • Cloud Backup
    • Cloud Registry
    • Yandex AI Studio
    • Compute Cloud
    • Object Storage
    • Managed Service for Kubernetes®
    • Yandex BareMetal
    • Smart Web Security
    • Security Deck
    • Managed Service for PostgreSQL
    • Managed Service for ClickHouse®
    • Monium
    • Cloud CDN
    • Network Load Balancer
    • Virtual Private Cloud
    • Cloud DNS
    • Application Load Balancer
    • Yandex Cloud Video
    • Stackland
    • Yandex Cloud Router
    • Yandex Managed Service for Trino
    • Managed Service for MySQL®
    • Managed Service for Valkey™
    • Managed Service for Apache Spark™
    • Yandex StoreDoc
    • Managed Service for OpenSearch
    • Managed Service for Apache Kafka®
    • Data Transfer
    • Yandex MPP Analytics Engine for PostgreSQL
    • Yandex Managed Service for Apache Airflow®
    • Data Processing
    • Yandex MetaData Hub
    • Managed Service for YDB
    • Managed Service for Sharded PostgreSQL
    • Managed Service for YTsaurus
    • Yandex WebSQL
    • DataLens
    • Yandex Search API
    • SpeechSense
    • SpeechKit
    • DataSphere
    • Vision OCR
    • Translate
    • Yandex Identity Hub
    • Key Management Service
    • Certificate Manager
    • Yandex Lockbox
    • Audit Trails
    • SmartCaptcha
    • Cloud Desktop
    • SourceCraft Code Assistant
    • Container Registry
    • Managed Service for GitLab
    • Managed Service for Prometheus®
    • Cloud Functions
    • API Gateway
    • Yandex Cloud Postbox
    • Message Queue
    • Serverless Integrations
    • IoT Core
    • Data Streams
    • Serverless Containers
    • Cloud Notification Service
    • Yandex Query
    • Identity and Access Management
    • Yandex Cloud Console
    • Resource Manager
    • Yandex Cloud Billing
    • Yandex Cloud Quota Manager
    • Cloud Apps
  • System Status
  • Marketplace
    • Featured
    • Infrastructure & Network
    • Data Platform
    • AI for business
    • Security
    • DevOps tools
    • Serverless
    • Monitoring & Resources
  • All Solutions
    • By industry
    • By use case
    • Economics and Pricing
    • Security
    • Technical Support
    • Start testing with double trial credits
    • Cloud credits to scale your IT product
    • Gateway to Russia
    • Cloud for Startups
    • Center for Technologies and Society
    • Yandex Cloud Partner program
    • Price calculator
    • Pricing plans
  • Customer Stories
  • Documentation
  • Blog
© 2026 Direct Cursus Technology L.L.C.
Yandex Data Streams
  • Access management
  • Pricing policy
    • Overview
    • All methods
      • CreateStream
      • DecreaseStreamRetentionPeriod
      • DeleteStream
      • DescribeStream
      • IncreaseStreamRetentionPeriod
      • GetRecords
      • GetShardIterator
      • ListStreams
      • PutRecord
      • PutRecords
      • UpdateShardCount
    • Common errors
    • Examples
  • FAQ

In this article:

  • Request
  • Request options
  • Response
  • Errors
  1. HTTP API compatible with Amazon Kinesis Data Streams
  2. Methods
  3. CreateStream

CreateStream

Written by
Yandex Cloud
Updated at August 15, 2025
View in Markdown
  • Request
    • Request options
  • Response
  • Errors

Creates a data stream.

On success, this method initiates stream creation, sets the stream status to CREATING, and returns an HTTP 200 response. Read and write operations are only permitted for streams with the ACTIVE status. To check the stream status, use the DescribeStream method.

If you attempt to create more streams than your account quota allows, the request will return LimitExceededException.

RequestRequest

The request contains JSON-formatted data.

{
  "StreamName": "string",
  "ShardCount": number,
  "WriteQuotaKbPerSec": number,
  "RetentionPeriodHours": number
}

Request optionsRequest options

Option Description
StreamName Data stream name.

Type: String
Size: 1-128 characters.
The possible values are: [a-zA-Z][a-zA-Z0-9-]+*(?<!-)$
Required: Yes
ShardCount Number of stream shards.

Type: Integer
Minimum value: 1.
Required: Yes
WriteQuotaKbPerSec Stream write throughput limit, KB/s.

Type: Integer
Allowed values: 128, 512, 1024.
Required: No
RetentionPeriodHours Record retention period, hours.

Type: Integer
Allowed values: 4, 12, 24.
Required: No

ResponseResponse

Successful responses include an HTTP 200 code and an empty response body.

ErrorsErrors

Error type Description HTTP code
InvalidArgumentException The argument is invalid. See the error message for details. 400
LimitExceededException The request limit is exceeded. 400
ResourceInUseException The resource is currently locked by another operation. 400

Errors common to all methods may occur.

Was the article helpful?

Previous
All methods
Next
DecreaseStreamRetentionPeriod
© 2026 Direct Cursus Technology L.L.C.