Questions tagged with Amazon Kinesis
Content language: English
Select up to 5 tags to filter
Sort by most recent
Browse through the questions and answers listed below or filter and sort to narrow down your results.
Trying to create a consumer to read records from kinesis data stream using php aws sdk 3.x. Found out that RegisterStreamConsumer is supported but not SubscribeToShard.
1
answers
0
votes
284
views
asked 2 years agolg...
Hi there,
I've installed the stream manager via pip, also installed the stream manager component via AWS console and everything looks healthy. I am trying to run these samples from github:...
0
answers
0
votes
154
views
asked 2 years agolg...
The **Kinesis Producer Library** aggregates records before sending them to a **Kinesis Data Stream**.
When consuming records from that **Data Stream** with the **Kinesis Consumer Library**, record...
1
answers
0
votes
517
views
asked 2 years agolg...
I am working on IoT project which require message order. Example I am monitoring elevator in the building. So when elevator moves from floor 1 to 10, I will receive MQTT message for each floor.
My...
1
answers
0
votes
602
views
asked 2 years agolg...
IoT Core to Kinesislg...
I can define action in IoT message rule and push data to Kinesis Data Stream(single shard). Since Kinesis is going to assign sequence number to the messages as they come from Iot Core.
Is there any...
1
answers
0
votes
333
views
asked 2 years agolg...
if I push IoT Core data to Kinesis Analytics as stream, how possible is to apply order by query to streaming data because you don't have complete data to call "order by" ?
My goal is pushing IoT Core...
2
answers
0
votes
264
views
asked 2 years agolg...
The following code is uploaded to Kinesis Analytics application:
```
from pyflink.datastream import StreamExecutionEnvironment
from pyflink.common.typeinfo import Types
from pyflink.common import...
1
answers
0
votes
348
views
asked 2 years agolg...
**Please investigate as a matter of urgency**
With regard to the hadoop client classes, there is an incompatibility in the jars loaded from the `/opt/flink/lib` directory. To reproduce the bug,...
0
answers
0
votes
135
views
asked 2 years agolg...
I am trying to use firehose and stream the CloudWatch log to private network (not AWS) HEC. In this case we need to open firewall between two component, as i know firehose is regional based which i...
0
answers
0
votes
62
views
asked 2 years agolg...
I'm running this code in a Zeppelin notebook (via Kinesis Analytics Studio), and it is not printing anything:
```
env.fromElements("a", "b", "c").print()
env.execute()
```
1
answers
0
votes
462
views
asked 2 years agolg...
Is anyone at AWS testing Glue?
I created a new table in my Glue Catalog, which is defined as a Kinesis stream. Then when I go to the Jobs editor and use the Visual Editor for a "Glue Catalog table ->...
1
answers
0
votes
273
views
asked 2 years agolg...
Hi team,
I would like to implement **real-time user activity monitoring** for our front-end application, to track all user's activities and show it to a **real-time dashboard**.
while searching I...
1
answers
0
votes
257
views
asked 2 years agolg...