Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

@aws-sdk/client-kinesis

Package Overview
Dependencies
Maintainers
5
Versions
428
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@aws-sdk/client-kinesis

AWS SDK for JavaScript Kinesis Client for Node.js, Browser and React Native

  • 3.682.0
  • Source
  • npm
  • Socket score

Version published
Weekly downloads
1M
increased by1.33%
Maintainers
5
Weekly downloads
 
Created

What is @aws-sdk/client-kinesis?

@aws-sdk/client-kinesis is an AWS SDK for JavaScript package that allows developers to interact with Amazon Kinesis, a platform for real-time data streaming. This package provides methods to create, manage, and interact with Kinesis streams, enabling real-time processing of data.

What are @aws-sdk/client-kinesis's main functionalities?

Create Stream

This feature allows you to create a new Kinesis stream. The code sample demonstrates how to create a stream named 'my-stream' with one shard.

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

const client = new KinesisClient({ region: 'us-east-1' });
const command = new CreateStreamCommand({ StreamName: 'my-stream', ShardCount: 1 });

client.send(command).then(
  (data) => console.log('Stream created:', data),
  (error) => console.error('Error creating stream:', error)
);

Put Record

This feature allows you to put a record into a Kinesis stream. The code sample demonstrates how to put a record with data 'my-data' into the stream 'my-stream' using a partition key.

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

const client = new KinesisClient({ region: 'us-east-1' });
const command = new PutRecordCommand({
  StreamName: 'my-stream',
  Data: Buffer.from('my-data'),
  PartitionKey: 'partition-key'
});

client.send(command).then(
  (data) => console.log('Record put:', data),
  (error) => console.error('Error putting record:', error)
);

Get Records

This feature allows you to get records from a Kinesis stream. The code sample demonstrates how to get records from the shard 'shardId-000000000000' of the stream 'my-stream'.

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

const client = new KinesisClient({ region: 'us-east-1' });
const shardIteratorCommand = new GetShardIteratorCommand({
  StreamName: 'my-stream',
  ShardId: 'shardId-000000000000',
  ShardIteratorType: 'TRIM_HORIZON'
});

client.send(shardIteratorCommand).then(
  (shardIteratorData) => {
    const getRecordsCommand = new GetRecordsCommand({ ShardIterator: shardIteratorData.ShardIterator });
    return client.send(getRecordsCommand);
  }
).then(
  (recordsData) => console.log('Records:', recordsData.Records),
  (error) => console.error('Error getting records:', error)
);

List Streams

This feature allows you to list all Kinesis streams in your account. The code sample demonstrates how to list all streams.

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

const client = new KinesisClient({ region: 'us-east-1' });
const command = new ListStreamsCommand({});

client.send(command).then(
  (data) => console.log('Streams:', data.StreamNames),
  (error) => console.error('Error listing streams:', error)
);

Other packages similar to @aws-sdk/client-kinesis

FAQs

Package last updated on 29 Oct 2024

Did you know?

Socket

Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.

Install

Related posts

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc