AI-200 Event Driven Integration Practice Test 8 — 15 Questions

Question 1

Your team is building an automated image moderation pipeline. When an image is uploaded to Azure Blob Storage, you need to trigger an Azure Function to process it using Azure AI Vision. You want to ensure the lowest latency and native cloud event integration. Which integration approach should you configure?

Choose an answer to begin — your selection is scored in the full session.

Accepted Answer

Configure an Azure Event Grid system topic and subscription for blob storage events targeting the Azure Function.. Azure Event Grid natively integrates with Blob Storage via system topics and delivers blob-created events to subscribers such as Azure Functions with near-real-time push delivery. This is the lowest-latency, event-driven pattern and requires no polling or intermediate queue.

Answer

Attach an Azure Event Hubs capture policy to the storage container.

Answer

Use an Azure Logic Apps polling trigger to check the storage container every minute for new files.

Answer

Write a background worker service that reads the Azure Service Bus queue populated by storage transactions.

Question 2

You are deploying an enterprise AI text-analysis system using Azure Service Bus topics and subscriptions. Downstream processing requires strict message ordering and session-aware processing so that related conversational turns are processed sequentially by the same worker instance. Which property must you enable on the Service Bus subscription?

Accepted Answer

Enable Sessions on the subscription and group messages using a Session ID.. Enabling sessions on the subscription is the only way to guarantee FIFO (first-in, first-out) ordering and affinity between related messages and a single processing instance. When a message is sent with a SessionId, Service Bus ensures that all messages with the same SessionId are delivered in order to the same receiver that holds the session lock. This directly satisfies the requirement that related conversational turns are processed sequentially by the same worker instance.

Answer

Enable Partitioning on the topic.

Answer

Set Duplicate Detection with a time window.

Answer

Configure Dead-lettering on message expiration.

Question 3

Your AI ingestion pipeline ingests millions of clickstream events per second from IoT devices and streams them into an Azure ML training pipeline. Which Azure service is specifically designed for high-throughput, low-latency telemetry ingestion at this scale?

Accepted Answer

Azure Event Hubs. Azure Event Hubs is designed for high-throughput, low-latency ingestion of telemetry data, capable of handling millions of events per second. It is optimized for streaming scenarios like IoT telemetry and clickstream data, making it ideal for this use case.

Answer

Azure Notification Hubs

Answer

Azure Event Grid

Answer

Azure Service Bus Queues

Question 4

You are implementing an event-driven architecture where an Azure Function acts as an Event Grid subscriber. Occasionally, the downstream cognitive service is throttled, causing failures. You need to ensure that unprocessable events are not lost and can be inspected later. Where should you configure a dead-letter destination?

Accepted Answer

On the Event Grid event subscription, specify an Azure Blob Storage container as the dead-letter endpoint.. Event Grid event subscriptions support a native dead-letter destination where events that cannot be delivered (after retries are exhausted) are stored as blobs in an Azure Storage container. This is configured on the event subscription itself, not on the subscriber, because Event Grid owns the delivery and retry lifecycle. The dead-lettered blob retains the original event payload plus failure metadata, enabling later inspection and reprocessing.

Answer

On the Azure Function trigger binding definition using the deadLetterQueueName property.

Answer

On the Azure Storage account firewall settings as an IP filter exception.

Answer

Inside the Azure Function application configuration settings as an Application Insights error sink.

Question 5

Your enterprise application uses Azure Service Bus Topics to broadcast AI model inference updates to multiple microservices. One particular subscriber requires filtering messages so it only receives updates where the 'ModelVersion' property is equal to 'v2' and the 'ConfidenceScore' is greater than 0.85. How should you implement this?

Accepted Answer

Create a SQL filter on the Service Bus subscription with the expression ModelVersion = 'v2' AND ConfidenceScore > 0.85.. Azure Service Bus subscriptions support SQL filters that evaluate against both system properties and user-defined custom properties (also called application properties) on the message. Because 'ModelVersion' and 'ConfidenceScore' are custom properties set by the publisher, a SQL filter expression like ModelVersion = 'v2' AND ConfidenceScore > 0.85 evaluates server-side at the subscription, so only matching messages are delivered to that subscriber. This is the native, most efficient mechanism for content-based routing on Service Bus Topics.

Answer

Create a boolean filter on the subscription matching a correlation ID of 'v2'.

Answer

Write custom middleware in the subscriber service to drop messages that do not meet the criteria after reading them from the topic.

Answer

Configure an Event Grid custom filter using advanced filters with an 'And' operator.

Question 6

An AI inference pipeline uses Azure Event Hubs to ingest telemetry. Your consumer application needs to read events starting from a specific timestamp to replay historical data for model retraining. Which feature of Event Hubs enables this capability?

Accepted Answer

Starting position based on Enqueued Time. Event Hubs consumers can specify a starting position using the Enqueued Time of events, allowing them to begin reading from a specific timestamp. This is implemented via the EventPosition.fromEnqueuedTime() method in the SDKs, which seeks to the first event with an enqueued time greater than or equal to the given timestamp. This feature is essential for replaying historical data for model retraining, as it lets the consumer skip older events and start at the desired point in time.

Answer

Event Hubs Capture window

Answer

Event Grid event retention policy

Answer

Service Bus message lock duration

Question 7

Your Azure Service Bus Premium namespace hosts critical AI request queues. Due to sudden spikes in inference requests, one of the queues experiences peak concurrency exceeding the maximum throughput units. You need to scale the namespace capacity automatically without manual intervention. What feature should you configure?

Accepted Answer

Enable Auto-inflate on the Service Bus namespace and specify the maximum messaging units.. Auto-inflate is the native Azure Service Bus Premium feature that automatically scales messaging units (throughput capacity) when the namespace approaches its limits, up to a configured maximum. It requires Premium tier and operates without manual intervention, making it the correct answer for handling sudden concurrency spikes on critical queues.

Answer

Configure geo-disaster recovery pairing with an active-active replication policy.

Answer

Enable Partitioning on the Service Bus queue entities.

Answer

Configure Azure Functions Premium plan scaling triggers based on Service Bus queue length.

Question 8

You are building an event-driven workflow where an external partner application needs to send custom events to your Azure backend. You decide to use Azure Event Grid Custom Topics. When the partner publishes an event, which event schema format must the JSON payload adhere to?

Accepted Answer

CloudEvents v1.0 schema or Event Grid schema. Azure Event Grid custom topics accept events in either the proprietary Event Grid schema or the CloudEvents v1.0 schema; both are valid JSON formats for publishing custom events. The partner must serialize the event payload according to one of these schemas, and the topic's input schema setting determines which one is expected. This ensures interoperability with CloudEvents-compliant systems while retaining the native Event Grid format for Azure-centric integrations.

Answer

OData v4 batch request format

Answer

SOAP 1.2 XML envelope format

Answer

AMQP 1.0 message format exclusively

Question 9

You are implementing an asynchronous AI processing pipeline using Azure Event Hubs. Multiple worker instances consume events from the same Event Hub. To prevent duplicate processing and ensure load balancing across workers, how should you manage consumer checkpoints?

Accepted Answer

Use the Azure Event Hubs EventProcessorClient with an Azure Blob Storage checkpoint store.. The EventProcessorClient is the recommended high-level client for consuming events from Event Hubs in .NET and other languages. It uses an Azure Blob Storage checkpoint store to persist checkpoints and partition ownership, enabling load balancing across multiple worker instances and preventing duplicate processing by resuming from the last checkpoint.

Answer

Configure Azure Service Bus auto-forwarding from Event Hubs to a queue.

Answer

Set the Event Hub partition retention period to zero.

Answer

Write custom code to maintain consumer offsets in a local memory cache on each worker instance.

Question 10

Your enterprise AI system uses Azure Service Bus. A background job processes messages from a subscription. If an exception occurs, the message must be abandoned, but you want to ensure that after 5 failed delivery attempts, the message is automatically moved to a dead-letter queue without custom retry logic in code. How should you configure this?

Accepted Answer

Set the MaxDeliveryCount property on the Service Bus subscription to 5.. The MaxDeliveryCount property on a Service Bus subscription (or queue) specifies how many times a message can be delivered before it is automatically dead-lettered. Setting it to 5 ensures that after 5 failed delivery attempts (where the message is abandoned or the lock expires), Service Bus moves it to the dead-letter queue without any custom retry logic.

Answer

Implement a Session-based retry policy with an exponential backoff timer.

Answer

Enable DeadLetteringOnMessageExpiration on the subscription settings.

Answer

Configure the LockDuration property to 5 seconds.

Question 11

You are developing a serverless AI notification workflow. When an AI model finishes training, it publishes an event to an Azure Event Grid topic. You want to trigger an Azure Logic App when this event occurs. Which Event Grid subscription event delivery schema and endpoint type should you select?

Accepted Answer

Select 'Webhook' as the endpoint type and provide the Logic Apps HTTP Request URL.. Azure Logic Apps expose an HTTP-triggered endpoint (the 'When an HTTP request is received' or Event Grid trigger URL) that Event Grid can invoke directly. Selecting 'Webhook' as the endpoint type and supplying the Logic App's HTTP Request URL lets Event Grid POST the event payload to the Logic App, which then parses it and runs the workflow. This is the standard, first-class integration pattern for Event Grid → Logic Apps.

Answer

Select 'Storage Queue' as the endpoint type.

Answer

Select 'Azure Service Bus Queue' as the endpoint type and provide the queue connection string.

Answer

Select 'Azure Event Hubs' as the endpoint type and provide the connection string.

Question 12

Your team is building an analytics pipeline where IoT telemetry data is ingested via Azure Event Hubs and needs to be continuously archived in Parquet format to an Azure Data Lake Storage Gen2 account for AI model training. Which built-in feature of Event Hubs should you enable?

Accepted Answer

Event Hubs Capture. Event Hubs Capture allows you to automatically capture streaming data in Event Hubs and save it to an Azure Blob Storage or Azure Data Lake Storage Gen2 account in Avro or Parquet format.

Answer

Service Bus Geo-Replication

Answer

Event Grid Auto-Routing

Answer

Stream Analytics Integration Job

Question 13

Your organization is implementing strict compliance standards. All event payloads transmitted through Azure Event Grid must be encrypted in transit using TLS 1.3 and encrypted at rest using a customer-managed key (CMK). Which Azure Event Grid tier supports configuring customer-managed keys?

Accepted Answer

Event Grid Premium tier. Customer-managed keys (CMK) for encryption at rest are supported only on the Event Grid Premium tier. Premium also supports Private Link, managed identity delivery, and higher throughput. Standard and Basic tiers do not support CMK configuration.

Answer

Event Grid Standard tier

Answer

Event Grid Basic tier

Answer

Event Grid Basic tier with custom schema extensions

Question 14

An AI application uses Azure Service Bus queues for task distribution. A background worker receives a message, but needs more time to complete the lengthy AI inference task before the message lock expires. Which method should the worker invoke?

Accepted Answer

RenewLockAsync. RenewLockAsync extends the lock on a message, giving the worker more time to process it before the lock expires. This prevents the message from being delivered to another worker while the current one is still processing.

Answer

AbandonAsync

Answer

DeadLetterAsync

Answer

CompleteAsync

Question 15

Your team is building an AI document parser. When a user uploads a PDF to Azure Blob Storage, an event triggers an Azure Function. You want to view the delivery success rate and latency metrics of these events in the Azure Portal. Which Azure service dashboard provides these metrics out-of-the-box?

Accepted Answer

Azure Event Grid Metrics. Azure Event Grid emits built-in platform metrics — including Publish Success Rate, Delivery Success Rate, Dropped Events, Matched Events, and delivery latency — that are surfaced automatically in the Azure Portal under the Event Grid topic or system topic's Metrics blade. No additional instrumentation is required to view these out-of-the-box.

Answer

Azure Container Apps Health Probes

Answer

Azure Cosmos DB Insights

Answer

Azure AI Services Dashboard