QuestionQ61

Data Ingestion and Data Preparation

An Architect is designing a data pipeline that loads JSON data from an untrusted source into Snowflake. The pipeline must handle cases in which the incoming JSON is malformed or includes invalid records.

Which components should the Architect use to satisfy these requirements?

Choose three
Explanation

A stream supplies the incremental set of newly changed input records, and a task runs SQL or calls a stored procedure to process that set as part of a continuous pipeline. A stored procedure with a Snowflake Scripting exception block can catch statement or expression errors and continue or otherwise handle invalid data, preventing a malformed or invalid record from necessarily stopping all processing.

Learn more

Community Discussion

No comments yet. Be the first to start the discussion!