Ingest Streaming Data DEA-C02 Practice Questions (Page 3)

Questions 11–15

1. 11application · medium

   A company is using the Snowflake Kafka connector to ingest data from multiple Kafka topics. They notice that some topics have higher throughput than others. They want to ensure that high-throughput topics do not starve lower-throughput topics. What should they do?

   • AIncrease the Kafka retention period to allow more time for the connector to catch up.
   • BSet the Snowflake table to use a larger cluster to handle the load.
   • CUse a single connector with a higher number of tasks to handle all topics.
   • DConfigure separate Snowflake Kafka connectors for each topic or group of topics with similar throughput.
   Reveal Solution Discussion Select an answer first
2. 12application · medium

   A financial services company needs to ingest real-time stock trade data into Snowflake with sub-second latency. The data is generated by a trading application that can be modified to send data directly to Snowflake. Which approach should they use?

   • AUse Snowpipe to load data from files that the application writes to a cloud storage stage.
   • BUse the Kafka connector to stream data from a Kafka topic that the application publishes to.
   • CUse a COPY INTO command scheduled every few seconds with a task.
   • DUse the Snowpipe Streaming API to insert rows directly into the target table from the application.
   Reveal Solution Discussion Select an answer first
4. 13application · medium

   A gaming company uses Amazon Kinesis Data Streams to collect player telemetry. They want to ingest this data into Snowflake for near-real-time dashboards. The data volume varies significantly, and they want to avoid over-provisioning compute. Which approach should they use?

   • AUse the Snowflake Kinesis connector to stream data from Kinesis into Snowflake tables.
   • BUse the Kafka connector with a Kinesis-to-Kafka bridge.
   • CSet up a Snowpipe to load data from files that a Lambda function writes to S3.
   • DManually run COPY INTO commands from a staging table populated by Kinesis Data Firehose.
   Reveal Solution Discussion Select an answer first
5. 14foundation · easy

   Which AWS service is typically used to deploy the Snowflake Kinesis connector?

   • AAmazon Athena
   • BAWS Lambda
   • CAmazon S3
   • DAmazon EC2
   Reveal Solution Discussion Select an answer first
6. 15foundation · easy

   What is the role of a pipe object in Snowpipe?

   • AIt defines the COPY INTO statement that specifies the source stage, target table, and file format
   • BIt stores the data files that are waiting to be loaded
   • CIt manages the virtual warehouse that executes the load
   • DIt provides a REST API endpoint for clients to push data directly
   Reveal Solution Discussion Select an answer first