kinesis_dataset {tfio}

Creates a KinesisDataset.

Description

Kinesis is a managed service provided by AWS for data streaming. This dataset reads messages from Kinesis with each message presented as a tf.string.

Usage

kinesis_dataset(stream, shard = "", read_indefinitely = TRUE, interval = 1e+05)

Arguments

stream

A tf.string tensor containing the name of the stream.

shard

A tf.string tensor containing the id of the shard.

read_indefinitely

If True, the Kinesis dataset will keep retry again on EOF after the interval period. If False, then the dataset will stop on EOF. The default value is True.

interval

The interval for the Kinesis Client to wait before it tries to get records again (in millisecond).