SnowPro Advanced: Architect

Question bank

Snowflake logo

SnowPro Advanced: Architect

ARA-C01

41 SnowPro Advanced: Architect questions with the correct answer and a written explanation, organised across 4 exam domains.

41 questions
4 domains
Foundation level

Question index

Jump straight to any question. Answers and explanations are inline.

Accounts & Security

10 questions in this domain

  1. Question 1Single Choice

    Which statement best describes idempotency in a data pipeline?

    • ARe-running the same load produces the same result without duplication.Correct answer
    • BThe pipeline can run only once and will never fail.
    • CThe pipeline automatically scales to handle large workloads.
    • DData is encrypted during transit and at rest.

    Why this is the answer

    Idempotency in pipelines ensures that repeated executions do not duplicate data, using techniques such as metadata tracking and staging tables.

  2. Question 2Multiple Select

    Which two techniques are commonly used to make Snowflake pipelines idempotent?

    • AUsing metadata tracking to record already-processed filesCorrect answer
    • BUsing staging tables to deduplicate before final insertCorrect answer
    • CDisabling all Tasks after a failed pipeline run
    • DRelying solely on random file names in external storage

    Why this is the answer

    Metadata tracking and staging tables are recommended to ensure re-runs are idempotent; disabling tasks or using random file names does not provide consistency.

  3. Question 3Interactive

    Review the SQL statement in the code block. Which Snowflake object is created and what is its main purpose?

    • AA stream that captures DML changes on the orders tableCorrect answer
    • BA task that runs scheduled SQL every minute
    • CA pipe that loads files from an external stage
    • DA dynamic table that refreshes automatically

    Why this is the answer

    CREATE STREAM creates a Snowflake Stream, which captures DML changes and supports change data capture for incremental processing.

  4. Question 4Single Choice

    What do Snowflake Streams provide for downstream pipelines?

    • AIncremental processing by capturing DML changesCorrect answer
    • BA permanent audit log of all historical transactions
    • CAutomatic query acceleration for large scans
    • DReplacement for virtual warehouses

    Why this is the answer

    Streams enable incremental processing by capturing DML changes, reducing the need for full table scans.

  5. Question 5Multiple Select

    Which two Snowflake features are used for orchestration and scheduled transformation logic?

    • ATasksCorrect answer
    • BDynamic TablesCorrect answer
    • CPipes
    • DStreams

    Why this is the answer

    Tasks provide scheduled or conditional execution, while Dynamic Tables provide declarative continuous refresh. Pipes handle loading; Streams handle CDC.

  6. Question 6Interactive

    The code block shows a scheduling object being created and enabled. What type of Snowflake object is it?

    • AA Snowflake TaskCorrect answer
    • BA Snowpipe
    • CA Stream
    • DA Dynamic Table

    Why this is the answer

    CREATE TASK and ALTER TASK RESUME create and enable a Snowflake Task for scheduled SQL execution.

  7. Question 7Single Choice

    What is required to enable automated Snowpipe ingestion from cloud storage?

    • AA cloud messaging service such as SQS or Event GridCorrect answer
    • BA dedicated multi-cluster warehouse
    • CA Dynamic Table with a refresh schedule
    • DA Snowflake Task running every minute

    Why this is the answer

    Automated Snowpipe requires a cloud notification service like SQS or Event Grid to signal the arrival of new files.

  8. Question 8Multiple Select

    Which two statements about Snowpipe compute are correct?

    • AIt uses Snowflake-managed compute resourcesCorrect answer
    • BIts compute is billed using serverless compute creditsCorrect answer
    • CIt uses a user-provisioned virtual warehouse
    • DIt requires an always-running warehouse

    Why this is the answer

    Snowpipe uses Snowflake-managed serverless compute and is billed through serverless credits, not virtual warehouse billing.

  9. Question 9Interactive

    The function in the code block is used for which observability purpose?

    • AStatus and error information for a SnowpipeCorrect answer
    • BThe number of rows loaded by a COPY command
    • CThe current warehouse credit usage
    • DThe last query ID on a task

    Why this is the answer

    SYSTEM$PIPE_STATUS returns pipe status and error information, helping architects monitor continuous ingestion pipelines.

  10. Question 10Single Choice

    What is the result of multiple downstream processes consuming the same Stream without a branching strategy?

    • AA Stream's changes are lost after consumption, causing data lossCorrect answer
    • BSnowpipe stops ingesting files
    • CAutomatic clustering is disabled
    • DA Task will run indefinitely

    Why this is the answer

    A Stream is consumed when read; without proper branching, a second consumer may miss changes, leading to data loss.

Data Engineering

10 questions in this domain

  1. Question 11Single Choice

    What does idempotency guarantee in a data pipeline?

    • ARe-running the same load produces the same result without duplicate dataCorrect answer
    • BThe pipeline automatically retries failed tasks every second
    • CSnowpipe uses the customer-provisioned virtual warehouse
    • DAll semi-structured data is flattened immediately upon ingestion

    Why this is the answer

    Idempotency ensures that re-running a load yields the same final state without duplication, typically using metadata tracking or staging tables.

  2. Question 12Multiple Select

    Which statements about Snowflake Streams for Change Data Capture are true?

    • AThey capture DML changes on tables or viewsCorrect answer
    • BThey enable incremental processing and reduce compute overheadCorrect answer
    • CThey are consumed when read by a downstream DML operationCorrect answer
    • DThey provide a permanent, exhaustive log of every change forever

    Why this is the answer

    Streams capture changes, allow incremental processing, and are consumed upon use; they are not permanent logs.

  3. Question 13Interactive

    The SQL statement shown is used to accomplish which task?

    • AMonitor the status of a pipe and detect errorsCorrect answer
    • BCreate a new pipe object
    • CValidate a COPY statement before loading
    • DDrop an existing pipe permanently

    Why this is the answer

    SYSTEM$PIPE_STATUS returns metadata about a pipe, enabling architects to monitor its state and identify ingestion problems.

  4. Question 14Single Choice

    How is Snowpipe compute usage billed?

    • AServerless compute creditsCorrect answer
    • BVirtual warehouse credits
    • CStorage credits
    • DData transfer credits

    Why this is the answer

    Snowpipe uses Snowflake-managed compute and is billed through serverless compute credits, not customer virtual warehouses.

  5. Question 15Multiple Select

    Which of the following are recognized traps when using Snowpipe for ingestion?

    • AAssuming Snowpipe uses the user's virtual warehouseCorrect answer
    • BOverlooking the need for a cloud messaging service such as SQS or Event GridCorrect answer
    • CUsing Snowpipe for massive, bulk historical migrationsCorrect answer
    • DAssuming a Stream can be consumed by multiple tasks without data loss

    Why this is the answer

    Snowpipe uses managed compute, requires notifications, and is not suited for multi-terabyte initial loads; Streams also have consumption limitations.

  6. Question 16Interactive

    What does the SQL statement shown create?

    • AA stream object that captures changes to the tableCorrect answer
    • BA pipe for automatically loading external files
    • CA task with a scheduled execution
    • DA dynamic table that refreshes continuously

    Why this is the answer

    CREATE STREAM creates a stream object that records DML changes on the specified table for incremental processing.

  7. Question 17Single Choice

    What is a key characteristic of Dynamic Tables in Snowflake?

    • AThey provide declarative, continuous data transformationCorrect answer
    • BThey require procedural conditional logic for each refresh
    • CThey replace the need for Snowflake Tasks entirely
    • DThey only work with external cloud storage stages

    Why this is the answer

    Dynamic Tables use a declarative model where Snowflake manages continuous refreshes automatically, contrasting with procedural Tasks.

  8. Question 18Multiple Select

    Why is the Star Schema generally preferred over the Snowflake Schema in Snowflake analytical workloads?

    • AIt minimizes the depth of joinsCorrect answer
    • BIt reduces the complexity of the execution planCorrect answer
    • CIt helps the optimizer use pruning techniques across large fact tablesCorrect answer
    • DIt eliminates the need for clustering keys on all tables

    Why this is the answer

    Star Schema reduces join depth, simplifies execution plans, and improves the optimizer's ability to prune large fact tables.

  9. Question 19Interactive

    The SQL statement shown represents which data loading pattern?

    • APull-based batch loading using COPY INTOCorrect answer
    • BPush-based continuous ingestion using Snowpipe
    • CEvent-driven loading triggered by SQS notifications
    • DStream-based replication from an OLTP source

    Why this is the answer

    The COPY INTO command is a pull-based batch loading pattern, typically scheduled for large-scale or periodic loads.

  10. Question 20Single Choice

    Which Slowly Changing Dimension type moves history to a separate table?

    • AType 4Correct answer
    • BType 1
    • CType 2
    • DType 0

    Why this is the answer

    SCD Type 4 moves history to a separate table, while Type 2 adds columns to the main dimension.

Performance Optimization

8 questions in this domain

  1. Question 21Single Choice

    In the Snowflake data loading model, which type of compute resources are used when Snowpipe executes an ingestion workload?

    • ASnowflake-managed serverless computeCorrect answer
    • BCustomer-provisioned virtual warehouse
    • CDedicated multi-cluster warehouse
    • DUser-specified warehouse from the COPY statement

    Why this is the answer

    Snowpipe ingests data using Snowflake-managed compute, not a customer virtual warehouse, and is billed through serverless credits.

  2. Question 22Multiple Select

    To automate Snowpipe so that file arrival in a stage triggers a load, which two components must be configured?

    • AA cloud messaging service (SQS or Event Grid)Correct answer
    • BA PIPE object with AUTO_INGEST enabledCorrect answer
    • CA virtual warehouse assigned to the pipe
    • DA scheduled task invoking the pipe

    Why this is the answer

    Automated Snowpipe requires an external notification mechanism and a PIPE object; it does not use a user-provisioned warehouse or scheduled task.

  3. Question 23Interactive

    The SQL defines a scheduled task that reads from a stream. What happens to the stream after the task successfully executes?

    • AStream offset advances and prior changes are hiddenCorrect answer
    • BRemains unchanged until a SELECT reads it
    • CDropped automatically
    • DKeeps all records for the next run

    Why this is the answer

    A stream is consumed by DML operations; after the INSERT executes, the offset advances and the previous changes are no longer visible.

  4. Question 24Single Choice

    For files that have already been loaded by a Snowpipe, what delivery semantics does the internal metadata guarantee?

    • AExactly-once deliveryCorrect answer
    • BAt-least-once delivery
    • CAt-most-once with manual deduplication
    • DNo deduplication guarantee

    Why this is the answer

    Snowpipe tracks file metadata to prevent duplicate ingestion, providing exactly-once delivery for files already processed.

  5. Question 25Multiple Select

    Which two statements are accurate when describing how Snowpipe operates and should be charged?

    • AIt uses Snowflake-managed compute creditsCorrect answer
    • BLarger micro-batches are more cost-effectiveCorrect answer
    • CIt runs on the user's virtual warehouse
    • DIt is ideal for multi-terabyte initial migrations

    Why this is the answer

    Snowpipe uses serverless compute, and aggregating files into larger micro-batches reduces cost; bulk historical migrations should use COPY INTO.

  6. Question 26Interactive

    The function shown returns pipe diagnostic information. Which two fields are most useful for detecting an ingestion failure?

    • AstatusCorrect answer
    • BlastErrorCorrect answer
    • CpipeName
    • Downer

    Why this is the answer

    In SYSTEM$PIPE_STATUS, status and lastError indicate whether the pipe is running and if an error has occurred.

  7. Question 27Single Choice

    For analytical query performance in Snowflake, which schema design is generally preferred over a normalized model?

    • AStar SchemaCorrect answer
    • BSnowflake Schema
    • CData Vault
    • DWide Table

    Why this is the answer

    Star schema is generally preferred in Snowflake because it reduces join depth and lets the optimizer prune data more effectively.

  8. Question 28Multiple Select

    Which two statements correctly describe the difference between SCD Type 2 and SCD Type 4 implementations?

    • AType 2 adds rows to the main dimensionCorrect answer
    • BType 4 stores history in a separate tableCorrect answer
    • CType 2 stores history only in a separate table
    • DType 4 adds columns to the main dimension

    Why this is the answer

    SCD Type 2 tracks history in the main dimension, while Type 4 moves history to a separate table, preventing dimension bloat.

Snowflake Architecture

13 questions in this domain

  1. Question 29Single Choice

    In Snowflake pipeline design, what does it mean for a data load to be idempotent?

    • ARe-running load produces same result without duplicatesCorrect answer
    • BLoad always scans the entire table
    • CPipeline uses external orchestration only
    • DPipeline never encounters failures

    Why this is the answer

    Idempotency means re-running the same load yields the same target state, preventing duplicate or corrupted results.

  2. Question 30Multiple Select

    Which two statements are true about using Snowflake Streams for change data capture in a pipeline?

    • AStreams capture DML changes for incremental processingCorrect answer
    • BAll downstream readers consume streams automatically
    • CStreams reduce compute overhead versus full scansCorrect answer
    • DStreams permanently retain all change records

    Why this is the answer

    Streams capture DML changes for incremental pipelines, but they are consumed by reads and are not permanent logs.

  3. Question 31Interactive

    Review the PIPE object in the code block. What is its main purpose for continuous ingestion?

    • AEncapsulates COPY statement and integration detailsCorrect answer
    • BProvisions a virtual warehouse
    • CCreates a stream for change tracking
    • DFlattens semi-structured data

    Why this is the answer

    A PIPE object encapsulates the COPY statement, integration details, and load metadata, preventing duplicate ingestion of processed files.

  4. Question 32Single Choice

    Which Snowflake feature provides declarative continuous data transformation without the need for procedural task code?

    • ATasks
    • BStreams
    • CDynamic TablesCorrect answer
    • DSnowpipe

    Why this is the answer

    Dynamic Tables provide declarative, set-based continuous refresh and simplify transformation pipelines compared to procedural Tasks.

  5. Question 33Multiple Select

    Which two statements correctly compare Snowpipe and COPY INTO for data loading pipelines in Snowflake?

    • ASnowpipe is best for near real-time micro-batchesCorrect answer
    • BCOPY INTO is best for large batch loadsCorrect answer
    • CSnowpipe is always cheaper than COPY INTO
    • DCOPY INTO requires a cloud notification service

    Why this is the answer

    Snowpipe is event-driven and suited for low latency micro-batches; COPY INTO is pull-based and better for large bulk loads.

  6. Question 34Interactive

    The function in the code block inspects a pipe. What kind of information does it return?

    • ACurrent pipe status and pending file countCorrect answer
    • BQuery execution plan details
    • CUser login and session history
    • DDaily warehouse credit usage

    Why this is the answer

    SYSTEM$PIPE_STATUS returns pipe status and pending file counts, which helps monitor continuous ingestion overall health.

  7. Question 35Single Choice

    Why can multiple downstream processes fail when they share a single Snowflake Stream without branching?

    • AStream automatically duplicates all changes
    • BOne consumer consumes changes; others miss themCorrect answer
    • CStream becomes read-only after first read
    • DStream grows until manually truncated

    Why this is the answer

    Streams are consumed when read; without a branching strategy, one consumer can consume changes another still needs.

  8. Question 36Multiple Select

    Which two components are required for automated, event-driven Snowpipe ingestion from external cloud storage?

    • ACloud messaging service such as SQSCorrect answer
    • BStorage notification from the cloud providerCorrect answer
    • CUser-managed virtual warehouse
    • DScheduled task from Snowflake

    Why this is the answer

    Automated Snowpipe requires cloud storage notifications and a messaging service; it does not require a user warehouse.

  9. Question 37Interactive

    The Task in the code block uses a CRON schedule. What execution time is defined?

    • AOnce every day at 2:00 AMCorrect answer
    • BOnce every hour at 2 minutes past
    • CEvery two seconds continuously
    • DOnly on Mondays at 2:00 PM

    Why this is the answer

    The CRON expression `0 2 * * *` schedules the task to run once every day at 02:00 AM, which is a daily schedule.

  10. Question 38Single Choice

    Which situation best illustrates the over-engineering trap in a modern Snowflake analytical pipeline architecture?

    • AUsing external Airflow when Tasks and Streams sufficeCorrect answer
    • BUsing Snowpipe for near real-time ingestion
    • CUsing COPY INTO for initial historical migration
    • DUsing Dynamic Tables for continuous refresh

    Why this is the answer

    The over-engineering trap is selecting a complex external orchestrator when Snowflake-native Tasks and Streams are simpler and cheaper.

  11. Question 39Multiple Select

    Which two practices help identify continuous pipeline stalls and schema mismatches in Snowflake?

    • AMonitoring pipe status with SYSTEM$PIPE_STATUSCorrect answer
    • BUsing VALIDATION_MODE to catch schema issuesCorrect answer
    • CDisabling error notifications on all pipes
    • DIgnoring task history for all scheduled jobs

    Why this is the answer

    SYSTEM$PIPE_STATUS and VALIDATION_MODE allow architects to catch pipe stalls and schema mismatches before BI is affected.

  12. Question 40Interactive

    The query in the code block references a denormalized fact table. How does columnar storage help?

    • AOnly referenced columns are scannedCorrect answer
    • BEvery column in the table is scanned
    • CCompression is disabled for all fact tables
    • DClustering key is required for query execution

    Why this is the answer

    Columnar storage scans only columns referenced by the query, which makes wide denormalized tables efficient for analytics.

  13. Question 41Single Choice

    What is a primary benefit of using Data Vault modeling for enterprise-scale integration in Snowflake?

    • AHigh agility and auditability with parallel loadingCorrect answer
    • BEliminates all query joins
    • CRequires only one source system
    • DPrevents all historical tracking

    Why this is the answer

    Data Vault supports agile integration, parallel loading, and scalable historical tracking without redesigning the core model.

Frequently asked questions

Everything about the SnowPro Advanced: Architect question bank and how to use it.