@aws-sdk/middleware-eventstream

What is @aws-sdk/middleware-eventstream?

@aws-sdk/middleware-eventstream is a middleware package for the AWS SDK for JavaScript. It provides functionality to handle event streams, which are used in various AWS services to deliver real-time data. This package is essential for working with services that use event streams, such as AWS Transcribe, AWS Kinesis, and others.

What are @aws-sdk/middleware-eventstream's main functionalities?

Event Stream Handling

This feature allows you to handle event streams by marshalling data into the event stream format. The code sample demonstrates how to create an event stream using the EventStreamMarshaller.

const { EventStreamMarshaller } = require('@aws-sdk/middleware-eventstream');

const marshaller = new EventStreamMarshaller();

const eventStream = marshaller.marshall({
  headers: {},
  body: Buffer.from('example event data')
});

console.log(eventStream);

Event Stream Unmarshalling

This feature allows you to unmarshall event streams back into their original data format. The code sample demonstrates how to unmarshall an event stream using the EventStreamMarshaller.

const { EventStreamMarshaller } = require('@aws-sdk/middleware-eventstream');

const marshaller = new EventStreamMarshaller();

const eventStream = Buffer.from('example event stream');
const event = marshaller.unmarshall(eventStream);

console.log(event);

Other packages similar to @aws-sdk/middleware-eventstream

event-stream

The event-stream package is a toolkit for working with streams in Node.js. It provides a variety of utilities for creating and manipulating streams, including event streams. Compared to @aws-sdk/middleware-eventstream, event-stream is more general-purpose and not specifically tailored for AWS services.

kinesis-client-library

The kinesis-client-library is a package for working with Amazon Kinesis streams. It provides high-level abstractions for consuming and processing data from Kinesis streams. While it focuses specifically on Kinesis, it offers similar event stream handling capabilities as @aws-sdk/middleware-eventstream.

README

@aws-sdk/middleware-eventstream

Changelog

3.616.0 (2024-07-18)

Bug Fixes

• lib-storage: location in upload result should include custom port (#6282) (9d3cbb6)
• middleware-sdk-s3: set consistent dependency versions (#6287) (207cd84)

Features

• client-acm-pca: Fix broken waiters for the acm-pca client. Waiters broke in version 1.13.144 of the Boto3 SDK. (a867f6e)
• client-connect: Amazon Connect expands search API coverage for additional resources. Search for hierarchy groups by name, ID, tag, or other criteria (new endpoint). Search for agent statuses by name, ID, tag, or other criteria (new endpoint). Search for users by their assigned proficiencies (enhanced endpoint) (226e9c6)
• client-ec2: Amazon VPC IP Address Manager (IPAM) now supports Bring-Your-Own-IP (BYOIP) for IP addresses registered with any Internet Registry. This feature uses DNS TXT records to validate ownership of a public IP address range. (337c43d)
• client-firehose: This release 1) Add configurable buffering hints for Snowflake as destination. 2) Add ReadFromTimestamp for MSK As Source. Firehose will start reading data from MSK Cluster using offset associated with this timestamp. 3) Gated public beta release to add Apache Iceberg tables as destination. (9a36c7e)
• client-medialive: AWS Elemental MediaLive now supports the SRT protocol via the new SRT Caller input type. (91134df)
• client-sagemaker: SageMaker Training supports R5, T3 and R5D instances family. And SageMaker Processing supports G5 and R5D instances family. (709db60)
• client-taxsettings: Set default endpoint for aws partition. Requests from all regions in aws partition will be forward to us-east-1 endpoint. (7927892)
• clients: update client endpoints as of 2024-07-18 (ac3e31b)