Build: Create Topic and Publish Events

0/1 steps

✓📚 Read

✓👁 See

✓🎞 Animate

✓🎯 Test

5⚙️ Build

Build Steps

Progress

0/1

◆ Before you start

Prerequisites

Azure SubscriptionRequired
az login
npm packageRequired
npm install @azure/eventgrid

📡

Step 1 of 1

Create Topic and Publish Events

Create an Event Grid custom topic and publish events from your app.

Tasks

Create custom topic via Azure CLI

Install @azure/eventgrid

Publish test events with EventGridPublisherClient

Create subscription to HTTP endpoint

🎯 What You'll Learn

▸Understand Event Grid topics vs system topics
▸Publish custom events with schema validation
▸Subscribe to events with webhook or Function endpoint

Code

TypeScriptpublish.ts
1 import { EventGridPublisherClient, AzureKeyCredential } from '@azure/eventgrid';
2  
3 const client = new EventGridPublisherClient(
4   process.env.TOPIC_ENDPOINT!,
5   'EventGrid',
6   new AzureKeyCredential(process.env.TOPIC_KEY!)
7 );
8  
9 async function publishOrderEvent(orderId: string, status: string) {
10   await client.send([{
11     eventType: 'Order.StatusUpdated',
12     subject: `orders/${orderId}`,
13     dataVersion: '1.0',
14     data: { orderId, status, timestamp: new Date().toISOString() },
15   }]);
16   console.log(`Published Order.StatusUpdated for ${orderId}`);
17 }
18  
19 publishOrderEvent('ord-123', 'shipped');

💡 Pro Tips

▸Use EventGrid schema for custom events; CloudEvents schema for portability
▸Filter by eventType in subscriptions to reduce noise

Expected Output

Event published to topic, webhook receives POST with event array

Discussion

1 import { EventGridPublisherClient, AzureKeyCredential } from '@azure/eventgrid'; 2 3 const client = new EventGridPublisherClient( 4 process.env.TOPIC_ENDPOINT!, 5 'EventGrid', 6 new AzureKeyCredential(process.env.TOPIC_KEY!) 7 ); 8 9 async function publishOrderEvent(orderId: string, status: string) { 10 await client.send([{ 11 eventType: 'Order.StatusUpdated', 12 subject: `orders/${orderId}`, 13 dataVersion: '1.0', 14 data: { orderId, status, timestamp: new Date().toISOString() }, 15 }]); 16 console.log(`Published Order.StatusUpdated for ${orderId}`); 17 } 18 19 publishOrderEvent('ord-123', 'shipped');

1	import { EventGridPublisherClient, AzureKeyCredential } from '@azure/eventgrid';
2
3	const client = new EventGridPublisherClient(
4	process.env.TOPIC_ENDPOINT!,
5	'EventGrid',
6	new AzureKeyCredential(process.env.TOPIC_KEY!)
7	);
8
9	async function publishOrderEvent(orderId: string, status: string) {
10	await client.send([{
11	eventType: 'Order.StatusUpdated',
12	subject: `orders/${orderId}`,
13	dataVersion: '1.0',
14	data: { orderId, status, timestamp: new Date().toISOString() },
15	}]);
16	console.log(`Published Order.StatusUpdated for ${orderId}`);
17	}
18
19	publishOrderEvent('ord-123', 'shipped');