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
.
kinesis_dataset(stream, shard = "", read_indefinitely = TRUE, interval = 1e+05)
stream | A |
---|---|
shard | A |
read_indefinitely | If |
interval | The interval for the Kinesis Client to wait before it tries to get records again (in millisecond). |