Font size
WorksheetsAmazon Kinesis
Total questions: 16
Worksheet time: 3hrs 10mins
Amazon Kinesis provides key capabilities in the form of
Kinesis Firehose – to easily load streaming data into AWS
Kinesis Analytics – to easily process and analyze streaming data with standard SQL
Kinesis Storm - to easily process unbounded streams of data.
Kinesis Video Streams - to capture, process, and store video streams for analytics.
Kinesis Streams – to build custom applications that process and analyze data.
You are deploying an application to track GPS coordinates of delivery trucks in the United States. Coordinates are transmitted from each delivery truck once every three seconds. You need to design an architecture that will enable real-time processing of these coordinates from multiple consumers.
Which service should you use to implement data ingestion?
Amazon Kinesis
AWS Data Pipeline
Amazon AppStream
Amazon Simple Queue Service
You are deploying an application to collect votes for a very popular television show. Millions of users will submit votes using mobile devices. The votes must be collected into a durable, scalable, and highly available data store for real-time public tabulation.
Which service should you use?
Amazon DynamoDB
Amazon Redshift
Amazon Kinesis
Amazon Simple Queue Service
Your company is in the process of developing a next generation pet collar that collects biometric information to assist families with promoting healthy lifestyles for their pets. Each collar will push 30kb of biometric data In JSON format every 2 seconds to a collection platform that will process and analyze the data providing health trending information back to the pet owners and veterinarians via a web portal.
Management has tasked you to architect the collection platform ensuring the following requirements are met:
1.) Allow for real-time analytics of the inbound biometric data
2.) Processing of the biometric data is durable, elastic and parallel.
3.) Results of the analytic processing should be persisted for data mining.
Which architecture outlined below will meet the initial requirements for the collection platform?
Utilize S3 to collect the inbound sensor data analyze the data from S3 with a daily scheduled Data Pipeline and save the results to a Redshift Cluster.
Utilize Amazon Kinesis to collect the inbound sensor data, analyze the data with Kinesis clients and save the results to a Redshift cluster using EMR.
Utilize SQS to collect the inbound sensor data analyze the data from SQS with Amazon Kinesis and save the results to a Microsoft SQL Server RDS instance.
Utilize EMR to collect the inbound sensor data, analyze the data from EUR with Amazon Kinesis and save me results to DynamoDB.
Your customer is willing to consolidate their log streams (access logs, application logs, security logs etc.) into one single system. Once consolidated, the customer wants to analyze these logs in real time based on heuristics. From time to time, the customer needs to validate heuristics, which requires going back to data samples extracted from the last 12 hours.
What is the best approach to meet your customer’s requirements?
Send all the log events to Amazon SQS. Setup an Auto Scaling group of EC2 servers to consume the logs and apply the heuristics.
Send all the log events to Amazon Kinesis develop a client process to apply heuristics on the logs.
Configure Amazon CloudTrail to receive custom logs, use EMR to apply heuristics the logs.
Setup an Auto Scaling group of EC2 syslogd servers, store the logs on S3 use EMR to apply heuristics on the logs.
You require the ability to analyze a customer’s clickstream data on a website so they can do behavioral analysis. Your customer needs to know what sequence of pages and ads their customer clicked on. This data will be used in real time to modify the page layouts as customers click through the site to increase stickiness and advertising click-through.
Which option meets the requirements for captioning and analyzing this data?
Log clicks in weblogs by URL store to Amazon S3, and then analyze with Elastic MapReduce
Write click events directly to Amazon Redshift and then analyze with SQL
Push web clicks by session to Amazon Kinesis and analyze behavior using Kinesis workers
Publish web clicks by session to an Amazon SQS queue men periodically drain these events to Amazon RDS and analyze with SQL
Your social media monitoring application uses a Python app running on AWS Elastic Beanstalk to inject tweets, Facebook updates and RSS feeds into an Amazon Kinesis stream. A second AWS Elastic Beanstalk app generates key performance indicators into an Amazon DynamoDB table and powers a dashboard application.
What is the most efficient option to prevent any data loss for this application?
Use AWS Data Pipeline to replicate your DynamoDB tables into another region
Use the second AWS Elastic Beanstalk app to store a backup of Kinesis data onto Amazon Elastic Block Store (EBS), and then create snapshots from your Amazon EBS volumes
Add a second Amazon Kinesis stream in another Availability Zone and use AWS data pipeline to replicate data across Kinesis streams
Add a third AWS Elastic Beanstalk app that uses the Amazon Kinesis S3 connector to archive data from Amazon Kinesis into Amazon S3
You need to replicate API calls across two systems in real time.
What tool should you use as a buffer and transport mechanism for API call events?
AWS SQS
AWS Lambda
AWS Kinesis
AWS SNS
You need to perform ad-hoc business analytics queries on well-structured data. Data comes in constantly at a high velocity. Your business intelligence team can understand SQL.
What AWS service(s) should you look to first?
Kinesis Firehose + RDS
Kinesis Firehose + RedShift
EMR using Hive
EMR running Apache Spark
A stock market monitoring application uses Amazon Kinesis for data ingestion. During simulated tests of peak data rates, the Kinesis stream cannot keep up with the incoming data.
What step will allow Kinesis to accommodate the traffic during peak hours?
Install the Kinesis Producer Library (KPL) for ingesting data into the stream
Reduce the data retention period to allow for more data ingestion using DecreaseStreamRetentionPeriod
Increase the shard count of the stream using UpdateShardCount
Ingest multiple records into the stream in a single call using PutRecords
You want to keep track of who is responsible for each of your data streams, so you decide to tag them by owner.
Which of these tag key/value pairs are allowed?
{ "aws-draco" : "scottrulez!" }
{ "draco-aws" : "Shu Lives" }
{ "aws:draco" : "H1S4nt4nu" }
{ "AWS Draco" : "Bill goes to 11" }
{ "tao@aws" : "Akshay writes really awesome/long quizzes" }
Your company has resources in the cloud with AWS and in a data center, connected via AWS Direct Connect. You have applications in both locations that generate logs as messages. You wish to capture them and process them inside your AWS environment.
How can you maximize effort and maintain security?
Create an Amazon EC2 instance in a private subnet inside the VPC, install the Amazon Kinesis agent on this instance and stream messages across AWS Direct Connect to the EC2 instance.
Create an Amazon EC2 instance in a private subnet inside the VPC, install the Amazon Kinesis agent on this instance, put a Load Balancer in front of the EC2 instance and stream messages across the Internet to the Load Balancer.
Use AWS DirectSync over AWS Direct Connect to stream messages to an Amazon S3 bucket. Use an Amazon Kinesis agent to process the messages.
Stream messages over AWS Direct Connect to a VPC Interface Endpoint bound to Amazon Kinesis.
A web application emits multiple types of events to Amazon Kinesis Streams for operational reporting. Critical events must be captured immediately before processing can continue, but informational events do not need to delay processing.
What is the most appropriate solution to record these different types of events?
Log all events using the Kinesis Producer Library
Log critical events using the Kinesis Producer Library, and log informational events using the PutRecords API method.
Log critical events using the PutRecords API method, and log informational events using the Kinesis Producer Library
Log all events using the PutRecords API method.
A mobile application collects data that must be stored in multiple Availability Zones within five minutes of being captured in the app.
What architecture securely meets these requirements?
The mobile app should write to an S3 bucket that allows anonymous PutObject calls
The mobile app should authenticate with an Amazon Cognito identity that is authorized to write to an Amazon Kinesis Firehose with an Amazon S3 destination
The mobile app should authenticate with an embedded IAM access key that is authorized to write to an Amazon Kinesis Firehose with an Amazon S3 destination
The mobile app should call a REST-based service that stores data on Amazon EBS. Deploy the service on multiple EC2 instances across two Availability Zones
An application is running on an Amazon EC2 instance in a private subnet. The application needs to read and write data on to Amazon Kinesis Data Streams, and corporate policy requires that this traffic should not go to the internet.
How can these requirements be met?
Configure a NAT gateway in a public subnet and route all traffic to Amazon Kinesis through the Nat gateway
Configure a gateway VPC endpoint for Kinesis and route all traffic to Kinesis through the gateway VPC endpoint
Configure an interface VPC endpoint for Kinesis and route all traffic to Kinesis through the interface VPC endpoint
Configure an AWS Direct Connect private virtual interface for Kinesis and route all traffic to Kinesis through the virtual interface
A Solutions Architect is designing a microservice to process records from Amazon Kinesis Streams. The metadata must be stored in Amazon DynamoDB. The microservice must be capable of concurrently processing 10000 records daily as they arrive in the Kinesis Stream.
The MOST scalable way to design the microservice is:
As an AWS Lambda function
As a process on an Amazon EC2 instance
As a Docker container on an EC2 instance
As a Docker container running on Amazon ECS
