AI-200 Event Driven Integration — 40 Questions

Question 1

Your application publishes messages to an Azure Service Bus topic. You want to ensure that messages published to the topic are automatically archived into an Azure Storage container for long-term auditing. Which native feature should you configure?

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

Accepted Answer

Deploy an Azure Function or Logic App triggered by the Service Bus topic subscriptions to write messages to Azure Blob Storage.. Azure Service Bus does not have a native 'Capture' feature like Event Hubs; however, you can configure Auto-Forwarding to a queue or use Azure Logic Apps / Azure Functions triggered by Service Bus to archive messages. (Wait, let's look closely at Service Bus features: Service Bus does not have native Capture like Event Hubs. Therefore, you must use an integration pattern like Azure Functions or Logic Apps).

Answer

Enable Geo-Disaster Recovery with Blob Storage as the secondary target.

Answer

Enable Service Bus Capture mode in the namespace configuration blade.

Answer

Configure Event Grid automated blob export on the topic.

Question 2

Your team is building an asynchronous order processing pipeline. If a downstream AI service fails to process a message from a Service Bus queue after 5 delivery attempts, the message must be automatically removed from active processing and preserved for manual inspection. What should you configure?

Accepted Answer

Configure the Max Delivery Count property on the queue and enable dead-lettering on message expiration or failure.. Azure Service Bus provides a dead-letter queue (DLQ) feature. When max delivery count is exceeded, the message is automatically moved to the DLQ for troubleshooting.

Answer

Enable Duplicate Detection with a history window of 5 attempts.

Answer

Set the AutoDeleteOnIdle property on the queue to 5 minutes.

Answer

Implement Event Grid dead-lettering pointing to an Azure Blob Storage container.

Question 3

Your enterprise application uses Azure Service Bus Topics to distribute orders to inventory and billing services. A transient database outage occurs in the billing service. You must ensure that billing messages are not lost and can be retried without interfering with the inventory service. What feature should you configure?

Accepted Answer

Configure separate subscriptions for each service under the Service Bus Topic.. Service Bus Subscriptions support sessions, dead-lettering, and independent subscriber configuration. Each subscription acts as a virtual queue, ensuring the billing service can process messages independently of inventory.

Answer

Enable partitioned queues on the sender application.

Answer

Use Event Grid filters to duplicate the messages into two separate storage accounts.

Answer

Implement Azure Relay to tunnel the database connection.

Question 4

An application publishes custom events to an Azure Event Grid custom topic. You need to route events dynamically based on the event's 'department' property in the event payload. Which filtering mechanism should you configure on the Event Grid subscription?

Accepted Answer

Advanced Filters. Event Grid supports Advanced Filters, which allow you cube or filter events based on specific JSON path properties in the data payload or event schema.

Answer

Event Hubs Capture filters

Answer

Subject Begins With/Ends With filters

Answer

Service Bus Correlation Filters

Question 5

You are integrating an Azure Event Hubs namespace with Azure Machine Learning for real-time model training. You need to archive raw telemetry data into Azure Data Lake Storage Gen2 in Apache Parquet format without writing custom code. Which feature should you enable?

Accepted Answer

Event Hubs Capture. Event Hubs Capture automatically packages streaming data into Avro or Parquet files and stores them directly in Azure Blob Storage or Azure Data Lake Storage Gen2.

Answer

Event Grid system topic with a Storage Blob export endpoint

Answer

Azure Stream Analytics job with a Blob output sink

Answer

Service Bus Geo-Disaster Recovery replication

Question 6

You are designing an asynchronous AI image classification workflow. Client applications upload images to Azure Blob Storage and need to be notified immediately when processing completes. The notification must include custom metadata generated by the AI worker. Which architecture should you implement?

Accepted Answer

The AI worker publishes a custom event to an Azure Event Grid Topic upon completion.. Publishing custom events to an Event Grid custom topic or system topic allows worker functions to emit structured events with custom payload metadata upon completion.

Answer

Use Azure Service Bus topics with session IDs set to the image hash.

Answer

Configure an Azure Storage queue that triggers whenever a blob is modified.

Answer

Poll the Azure Blob Storage container metadata every 5 seconds from the client app.

Question 7

You are designing an AI application that needs to route real-time telemetry events from thousands of IoT devices to multiple downstream serverless functions simultaneously. Which Azure service should you use as the event broker?

Accepted Answer

Azure Event Grid. Azure Event Grid is designed for reactive programming and reliable event routing at scale, making it ideal for routing telemetry metadata or state changes to serverless functions.

Answer

Azure Service Bus Queues

Answer

Azure Event Hubs

Answer

Azure Blob Storage

Question 8

Your organization requires that all messages sent to an Azure Service Bus Premium namespace are encrypted using customer-managed keys (CMK) stored in Azure Key Vault. Where must you configure this encryption setting?

Accepted Answer

At the Service Bus Namespace level. Customer-managed keys for Azure Service Bus are configured at the Namespace level using Azure Key Vault integration.

Answer

Inside the Event Grid subscription endpoint URI

Answer

At the individual Queue or Topic level

Answer

Within the Azure Function consumer application configuration

Question 9

You are architecting an AI-driven video analytics pipeline using Azure Event Hubs. You need to ensure that frames belonging to the exact same video session are processed in strict chronological order by the same backend stream analytics worker. How should you partition your Event Hub?

Accepted Answer

Include the video session ID as the Partition Key when publishing events to the Event Hub.. To guarantee ordered processing for a specific entity, you must use a Partition Key when sending events to Event Hubs. All events with the same partition key are automatically routed to the same underlying partition.

Answer

Increase the consumer group count to match the number of active video sessions.

Answer

Set the message TTL to zero and enable capture mode on the Event Hub namespace.

Answer

Deploy an Azure Service Bus Session-enabled queue in front of the Event Hubs ingestion layer.

Question 10

You are developing a serverless application using Azure Functions that reacts to Azure Blob Storage creation events. Which event schema format should your function code expect by default when triggered by an Event Grid subscription?

Accepted Answer

Azure Event Grid schema. Event Grid sends events using either the CloudEvents 1.0 schema or the Event Grid schema. The default Azure Event Grid schema includes fields like id, topic, subject, data, eventType, and eventTime.

Answer

Apache Kafka record batch schema

Answer

AMQP 1.0 message envelope

Answer

SOAP XML envelope

Question 11

You are configuring geo-disaster recovery for an Azure Service Bus Premium namespace containing critical financial transactions. A regional outage occurs. After initiating a failover to the secondary region, what happens to the alias pointing to the namespace?

Accepted Answer

The alias automatically points to the secondary namespace, and pairing is broken.. Service Bus Geo-DR uses an alias. When failover is triggered, the alias is remapped to point to the secondary namespace, allowing clients to reconnect automatically without changing connection strings if they use the alias.

Answer

The secondary namespace remains in Read-Only mode until manually unlocked.

Answer

The alias becomes invalid, and you must deploy a new Service Bus namespace from scratch.

Answer

Unreplicated messages in the primary queue are automatically migrated in real-time.

Question 12

Your Azure Event Hubs namespace is experiencing high throughput spikes from AI inference nodes. You notice that some client producers are receiving 'QuotaExceededException' errors. What is the root cause and how should you remediate it?

Accepted Answer

Ingress or egress limits have been exceeded; enable Auto-Inflate on the Event Hubs namespace.. Event Hubs throughput is governed by Throughput Units (TUs) or Processing Units (PUs) in dedicated clusters. Exceeding ingress or egress limits triggers QuotaExceededException. Remediation involves scaling up TUs or enabling Auto-Inflate.

Answer

The partition count has been exceeded; decrease the number of consumer groups.

Answer

The SAS token has expired; regenerate the connection string.

Answer

The message retention period has expired; increase retention days.

Question 13

You are implementing distributed tracing across an event-driven AI workflow that passes messages from Azure Service Bus to Azure Functions, and finally to an Azure Cosmos DB database. Which mechanism should you use to propagate correlation context between these services?

Accepted Answer

W3C Trace Context standard HTTP headers (such as traceparent) propagated through Service Bus message user properties.. OpenTelemetry and W3C Trace Context standards (using headers like `traceparent`) are automatically injected and propagated by Azure Service Bus client libraries and Azure Functions bindings.

Answer

Enabling Azure Monitor diagnostic logs on the storage account.

Answer

Using AMQP 1.0 session locks to lock the trace state across network boundaries.

Answer

Custom GUID generation stored exclusively in the Event Grid event subject field.

Question 14

Your team needs to process high-volume clickstream data from a web application using Apache Kafka protocols while leveraging Azure-managed infrastructure. Which Azure service should you deploy?

Accepted Answer

Azure Event Hubs. Azure Event Hubs provides a native Kafka endpoint, allowing existing Kafka producer and consumer applications to talk to Event Hubs without changing code.

Answer

Azure Event Grid

Answer

Azure Notification Hubs

Answer

Azure Service Bus

Question 15

An event subscriber endpoint hosted on an Azure App Service web app is failing to receive events from an Azure Event Grid system topic. Upon investigation, you discover Event Grid received a handshake validation failure. What is the most likely cause?

Accepted Answer

The web app did not correctly handle and echo back the validation code during the Webhook handshake.. When creating an Event Grid subscription, Event Grid sends a Subscription Validation event with a validation code. The endpoint must respond with the validation code to prove ownership before events are delivered.

Answer

The event payload exceeded the 1 megabyte size limit.

Answer

The Service Bus connection string was incorrectly formatted.

Answer

The App Service pricing tier does not support HTTPS connections.

Question 16

You are designing a message-based architecture in Azure Service Bus where certain high-priority messages must bypass standard messages in the queue and be processed immediately. What feature should you implement?

Accepted Answer

Implement custom application logic that peeks and receives messages by sequence number, while utilizing multiple queues for high versus low priority.. Azure Service Bus supports message deferral and dead-lettering, but for out-of-order priority processing, developers can implement message prioritization using multiple queues or retrieve messages by sequence number using Peek/Receive methods.

Answer

Enable Express Queues to bypass disk I/O for high-priority messages.

Answer

Configure Event Grid priority routing filters.

Answer

Set the Priority property on the BrokeredMessage header to 10.

Question 17

Your organization uses Azure Event Grid to route cloud events across different departments. Security auditors require that all event traffic destined for a webhook endpoint is authenticated using Azure Active Directory (Microsoft Entra ID) bearer tokens. How should you configure the event subscription?

Accepted Answer

Configure a Managed Identity on the event subscription and select the target audience.. Event Grid allows you to configure Managed Identity (System-assigned or User-assigned) for webhook subscriptions so that Event Grid attaches a Microsoft Entra ID bearer token in the authorization header when invoking the webhook.

Answer

Enable IP firewall rules on the Event Grid topic to restrict traffic.

Answer

Use Basic Authentication with a static API key stored in App Settings.

Answer

Embed a Shared Access Signature (SAS) token directly in the webhook URL query parameters.

Question 18

You are writing a Python worker application that consumes messages from an Azure Service Bus queue. To prevent message loss during unexpected application crashes, you need to ensure that messages are locked while being processed and only deleted from the queue after successful processing. Which receive mode should you use?

Accepted Answer

PeekLock mode. PeekLock mode receives the message and locks it in the broker for a specified lock duration, preventing other consumers from processing it. The application must explicitly call complete() to delete it or abandon/dead-letter it on failure.

Answer

Deferred mode

Answer

SessionLock mode

Answer

ReceiveAndDelete mode

Question 19

You are designing a multi-tenant AI ingestion pipeline using Azure Event Hubs. You need to ensure that low-priority tenants cannot starve high-priority tenants of partition resources. Which feature should you implement?

Accepted Answer

Deploy separate Event Hubs namespaces for high-priority and low-priority tenants.. Event Hubs Dedicated clusters support capacity management and partitioning strategies, but for fine-grained client isolation, developers can use Partition Key isolation or separate namespaces.

Answer

Set the Capture interval to 60 seconds for low-priority partitions.

Answer

Configure RBAC permissions to restrict low-priority tenants to Reader roles.

Answer

Enable Azure DDoS Protection Standard on the Event Hubs consumer group.

Question 20

Your team needs to monitor when virtual machines are created or deleted across an entire Azure subscription so that an automated audit logger is triggered. Which Azure service should you use to capture these management plane operations?

Accepted Answer

Azure Event Grid. Azure Event Grid provides built-in integration with Azure Resource Manager (ARM), allowing you to subscribe to subscription-level and resource-group-level management events.

Answer

Azure Logic Apps

Answer

Azure Service Bus

Answer

Azure Event Hubs