Azure Event Hubs client library samples with persistent checkpointing for TypeScript

These sample programs show how to use the TypeScript client libraries for Azure Event Hubs in some common scenarios.

File Name Description
receiveEventsUsingCheckpointStore.ts Demonstrates how to use the BlobCheckpointStore with EventHubConsumerClient to process events from all partitions of a consumer group in an Event Hubs instance.
receiveEventsWithApiSpecificStorage.ts Demonstrates how to use a specific Azure Storage Blobs API version with BlobCheckpointStore.

Prerequisites

The samples are compatible with Node.js >= 8.0.0.

Before running the samples in Node, they must be compiled to JavaScript using the TypeScript compiler. For more information on TypeScript, see the TypeScript documentation. Install the TypeScript compiler using

npm install -g typescript

You need an Azure subscription, an Azure Event Hub resource and an Azure Storage account to run these sample programs. The IOT Hub sample additionally requires an [IOT Hub resource][aziothub]. Samples retrieve credentials to access the event hub from environment variables. Alternatively, edit the source code to include the appropriate credentials. See each individual sample for details on which environment variables/credentials it requires to function.

Adapting the samples to run in the browser requires some additional consideration. For details, please see the package README.

Setup

To run the samples using the published version of the package:

  1. Install the dependencies using npm:
npm install
  1. Edit the sample file you plan to run to use the correct credentials to access the Azure services.

  2. Compile the samples

npm run build
  1. Run whichever samples you like (note that some samples may require additional setup):
node dist/receiveEventsUsingCheckpointStore.js

Next Steps

Take a look at our API Documentation for more information about the APIs that are available in the clients.