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.
(technically I really want to make kinesis talk to redshift, but I'm debugging redshift permissions via my outside IP address)
I have enabled external access in the redshift configs.
I'm using the...
2
answers
0
votes
398
views
asked a year agolg...
We run our ETLs using the below architecture to populate the datalake :
MySQL -> DMS -> S3 -> Glue -> S3
Though this architecture works fine , its heavily dependent on the Database. Also the object...
1
answers
0
votes
249
views
asked a year agolg...
Hello,
Is there a way to start a KDA application using another's snapshot if both are compatible? It looks like snapshots are coupled to individual applications.
Thanks!
1
answers
1
votes
280
views
asked a year agolg...
Has anyone found where Amazon Connect historical and real-time reports are stored, S3 or otherwise? For example, I have a historical report for agents status that runs every 30 minutes, and stores...
2
answers
0
votes
477
views
asked 2 years agolg...
The main purpose of my program is to connect to an incoming MQTT channel, and send the data received to my AWS Kinesis Stream called "MyKinesisStream".
Here is my code:
```
import argparse
import...
1
answers
0
votes
297
views
asked 2 years agolg...
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
293
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
159
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
532
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
614
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
337
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
267
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
352
views
asked 2 years agolg...