Student Blog

Build Real-Time Dashboard on Amazon Webservices

October 21, 2020

The blog is posted by WeCloudData’s student Luis Vieira.

kibana dashboard on amazon webservices showing a map and data

  • Build a Real-time Stream Processing Pipeline with Apache Flink on Amazon Webservices;
  • Build and Run Streaming Applications with Amazon Kinesis and Firehose Consumer.

In today’s business environments, data is generated in a continuous fashion by a steadily increasing number of diverse data sources.


A reliable and scalable streaming architecture based on Flink, Kinesis Data Streams, and Kinesis Data Firehose

  1. Service Level Agreement — Requirements
  • Consistency
  • Low latency
  • High availability
  • High throughput
  • Scale
  • Data durability
stream process pipeline example
process pipeline showing amazon emr
process pipeline elements
Implement Elements

2. Building elements

  • Create the streams to capture and store the taxi fleet records; – Add or remove shards to scale throughput;
  • Provision and manage cluster for your big data needs (EMR) – Apache Flink (Read events from kinesis, process performing transformation);
  • Setup Elasticsearch cluster to integrate with Kibana;
  • Lambda:

– Cloud Formation/Flink (Supports the stack and populates);

– Firehose (Transform records and load to Elasticsearch Service);

  • Set up Firehose to delivery stream data;
  • Inspect derived data with Kibana;

3. Let’s demo using Cloud Formation — Apache Flink

**Before you start, you will need to create an AWS Account.

3.1. CloudFormation-Flink: Building the runtime artifacts and creating the infrastructure

  • Execute the first CloudFormation template to create an AWS CodePipeline pipeline, which builds the artifacts by means of AWS CodeBuild in a serverless fashion: Execute HERE. (check your region*)
  • When the first template is created and the runtime artifacts are built, execute the second CloudFormation template, which creates the resources of the reference architecture described earlier: Execute HERE. (check your region*)

3.2. Set Flink on EMR: Enable Web Connection

  • *You will have this screen.
emr weblink connection

Step 1: Open an SSH Tunnel to the Amazon EMR Master Node;

Download PuTTY: latest release (0.74)

This page contains download links for the latest released version of PuTTY. Currently this is 0.74, released on…

Step 2: Configure a proxy management tool;

  • Step 1: EMR-EC2
  • Step 2: Flink Interface

**You will have your region and flags/checkpoint accordingly to the one generated for your environment. The above was generated when I was creating this post.

3.3. Ingesting trip events into the Amazon Kinesis stream

**You will have your region and flags/checkpoint accordingly to the one generated for your environment. The above was generated when I was creating this post.

3.4 Exploring Kibana

3.5 Scaling

4. Let’s demo using Kinesis Firehose

Building the runtime artifacts and creating the infrastructure. (Steps)

4.1 Create Kinesis Stream Data.

4.2 Connect Kinesis consumers.

  • Delivery records with Firehose.

4.3 Create Firehose

  • Enable Lambda to transform source records (taxi fleet records);
  • Specify the index for ES (**Kibana index);
  • Select Elasticsearch Service destination;
  • Set bucket to backup;

4.4 Inspect derived data with Kibana

Exploring Kibana

5. References

New York City Taxi and Limousine Commission (TLC) Trip Record Data

Data of Trips taken by taxis and for-hire vehicles in New York City.

I hope this blog helped you clearing concepts regarding Real-Time Stream Data and Dashboard on AWS. Don’t forget to like this blog if you genuinely liked it.

Follow for more awesome blogs!

To find out more about the courses our students have taken to complete these projects and what you can learn from WeCloudData, click here to see the learning path. To read more posts from Luis, check out his Medium posts here.

Join our programs and advance your career in Cloud EngineeringData EngineeringData Science

"*" indicates required fields

This field is for validation purposes and should be left unchanged.
Other blogs you might like
Career Guide
It has been approximately one year since I decided to make a career switch from Civil Engineering to the…
by Student WeCloudData
February 10, 2020
Student Blog
The blog is posted by WeCloudData’s Big Data course student Abhilash Mohapatra. This story represents an easy path for…
by Student WeCloudData
May 12, 2020
Student Blog
The blog is posted by WeCloudData’s Bid Data course student Udayan Maurya. Customer reviews are invaluable information to understand the…
by Student WeCloudData
May 28, 2020

Kick start your career transformation