Moving samples to the azure-event-hubs repo (#142)
* Moving samples to the azure-event-hubs repo * Fixes
This commit is contained in:
Seth Manheim
SJ
Родитель
9088ebde91
Коммит
82e418a7f6
|
|
@ -20,12 +20,6 @@ Project("{8BB2217D-0F2D-49D1-97BC-3654ED321F3B}") = "Microsoft.Azure.EventHubs.P
|
|||
EndProject
|
||||
Project("{8BB2217D-0F2D-49D1-97BC-3654ED321F3B}") = "Microsoft.Azure.EventHubs.Processor.UnitTests", "test\Microsoft.Azure.EventHubs.Processor.UnitTests\Microsoft.Azure.EventHubs.Processor.UnitTests.xproj", "{F7F892F4-4490-4BC9-BB18-F42F2C85E345}"
|
||||
EndProject
|
||||
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "samples", "samples", "{188550D8-80F0-410D-AECA-BC3C1F96CF95}"
|
||||
EndProject
|
||||
Project("{8BB2217D-0F2D-49D1-97BC-3654ED321F3B}") = "SampleSender", "samples\SampleSender\SampleSender.xproj", "{940BCA4A-B154-4667-8A03-57E6B689866D}"
|
||||
EndProject
|
||||
Project("{8BB2217D-0F2D-49D1-97BC-3654ED321F3B}") = "SampleEphReceiver", "samples\SampleEphReceiver\SampleEphReceiver.xproj", "{679DFCC5-76BD-4725-A51E-AFBB01565401}"
|
||||
EndProject
|
||||
Global
|
||||
GlobalSection(SolutionConfigurationPlatforms) = preSolution
|
||||
Debug|Any CPU = Debug|Any CPU
|
||||
|
|
|
|||
|
|
@ -1,4 +1,4 @@
|
|||
<p align="center">
|
||||
<p align="center">
|
||||
<img src="event-hubs.png" alt="Microsoft Azure Event Hubs" width="100"/>
|
||||
</p>
|
||||
|
||||
|
|
@ -39,9 +39,9 @@ consumers that filter and/or transform event streams and then forward them on to
|
|||
|
||||
### Getting Started
|
||||
|
||||
To get started sending events to an Event Hub refer to [Get started sending messages to Event Hubs in .NET Core](./samples/SampleSender/readme.md).
|
||||
To get started sending events to an Event Hub refer to [Get started sending messages to Event Hubs in .NET Core](https://github.com/Azure/azure-event-hubs/tree/master/samples/SampleSender).
|
||||
|
||||
To get started receiving events with the **EventProcessorHost** refer to [Get started receiving messages with the EventProcessorHost in .NET Core](./samples/SampleEphReceiver/readme.md ).
|
||||
To get started receiving events with the **EventProcessorHost** refer to [Get started receiving messages with the EventProcessorHost in .NET Core](https://github.com/Azure/azure-event-hubs/tree/master/samples/SampleEphReceiver).
|
||||
|
||||
### Running the unit tests
|
||||
|
||||
|
|
|
|||
|
|
@ -1,47 +0,0 @@
|
|||
// Copyright (c) Microsoft. All rights reserved.
|
||||
// Licensed under the MIT license. See LICENSE file in the project root for full license information.
|
||||
|
||||
namespace SampleEphReceiver
|
||||
{
|
||||
using System;
|
||||
using System.Threading.Tasks;
|
||||
using Microsoft.Azure.EventHubs;
|
||||
using Microsoft.Azure.EventHubs.Processor;
|
||||
|
||||
public class Program
|
||||
{
|
||||
private const string EhConnectionString = "{Event Hubs connection string}";
|
||||
private const string EhEntityPath = "{Event Hub path/name}";
|
||||
private const string StorageContainerName = "{Storage account container name}";
|
||||
private const string StorageAccountName = "{Storage account name}";
|
||||
private const string StorageAccountKey = "{Storage account key}";
|
||||
|
||||
private static readonly string StorageConnectionString = string.Format("DefaultEndpointsProtocol=https;AccountName={0};AccountKey={1}", StorageAccountName, StorageAccountKey);
|
||||
|
||||
public static void Main(string[] args)
|
||||
{
|
||||
MainAsync(args).GetAwaiter().GetResult();
|
||||
}
|
||||
|
||||
private static async Task MainAsync(string[] args)
|
||||
{
|
||||
Console.WriteLine("Registering EventProcessor...");
|
||||
|
||||
var eventProcessorHost = new EventProcessorHost(
|
||||
EhEntityPath,
|
||||
PartitionReceiver.DefaultConsumerGroupName,
|
||||
EhConnectionString,
|
||||
StorageConnectionString,
|
||||
StorageContainerName);
|
||||
|
||||
// Registers the Event Processor Host and starts receiving messages
|
||||
await eventProcessorHost.RegisterEventProcessorAsync<SimpleEventProcessor>();
|
||||
|
||||
Console.WriteLine("Receiving. Press enter key to stop worker.");
|
||||
Console.ReadLine();
|
||||
|
||||
// Disposes of the Event Processor Host
|
||||
await eventProcessorHost.UnregisterEventProcessorAsync();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -1,21 +0,0 @@
|
|||
// Copyright (c) Microsoft. All rights reserved.
|
||||
// Licensed under the MIT license. See LICENSE file in the project root for full license information.
|
||||
|
||||
using System.Reflection;
|
||||
using System.Runtime.InteropServices;
|
||||
|
||||
// General Information about an assembly is controlled through the following
|
||||
// set of attributes. Change these attribute values to modify the information
|
||||
// associated with an assembly.
|
||||
[assembly: AssemblyConfiguration("")]
|
||||
[assembly: AssemblyCompany("")]
|
||||
[assembly: AssemblyProduct("SampleReceiver")]
|
||||
[assembly: AssemblyTrademark("")]
|
||||
|
||||
// Setting ComVisible to false makes the types in this assembly not visible
|
||||
// to COM components. If you need to access a type in this assembly from
|
||||
// COM, set the ComVisible attribute to true on that type.
|
||||
[assembly: ComVisible(false)]
|
||||
|
||||
// The following GUID is for the ID of the typelib if this project is exposed to COM
|
||||
[assembly: Guid("679dfcc5-76bd-4725-a51e-afbb01565401")]
|
||||
|
|
@ -1,21 +0,0 @@
|
|||
<?xml version="1.0" encoding="utf-8"?>
|
||||
<Project ToolsVersion="14.0" DefaultTargets="Build" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
|
||||
<PropertyGroup>
|
||||
<VisualStudioVersion Condition="'$(VisualStudioVersion)' == ''">14.0</VisualStudioVersion>
|
||||
<VSToolsPath Condition="'$(VSToolsPath)' == ''">$(MSBuildExtensionsPath32)\Microsoft\VisualStudio\v$(VisualStudioVersion)</VSToolsPath>
|
||||
</PropertyGroup>
|
||||
|
||||
<Import Project="$(VSToolsPath)\DotNet\Microsoft.DotNet.Props" Condition="'$(VSToolsPath)' != ''" />
|
||||
<PropertyGroup Label="Globals">
|
||||
<ProjectGuid>679dfcc5-76bd-4725-a51e-afbb01565401</ProjectGuid>
|
||||
<RootNamespace>SampleReceiver</RootNamespace>
|
||||
<BaseIntermediateOutputPath Condition="'$(BaseIntermediateOutputPath)'=='' ">.\obj\</BaseIntermediateOutputPath>
|
||||
<OutputPath Condition="'$(OutputPath)'=='' ">.\bin\</OutputPath>
|
||||
<TargetFrameworkVersion>v4.5.2</TargetFrameworkVersion>
|
||||
</PropertyGroup>
|
||||
|
||||
<PropertyGroup>
|
||||
<SchemaVersion>2.0</SchemaVersion>
|
||||
</PropertyGroup>
|
||||
<Import Project="$(VSToolsPath)\DotNet\Microsoft.DotNet.targets" Condition="'$(VSToolsPath)' != ''" />
|
||||
</Project>
|
||||
|
|
@ -1,44 +0,0 @@
|
|||
// Copyright (c) Microsoft. All rights reserved.
|
||||
// Licensed under the MIT license. See LICENSE file in the project root for full license information.
|
||||
|
||||
namespace SampleEphReceiver
|
||||
{
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Text;
|
||||
using System.Threading.Tasks;
|
||||
using Microsoft.Azure.EventHubs;
|
||||
using Microsoft.Azure.EventHubs.Processor;
|
||||
|
||||
public class SimpleEventProcessor : IEventProcessor
|
||||
{
|
||||
public Task CloseAsync(PartitionContext context, CloseReason reason)
|
||||
{
|
||||
Console.WriteLine($"Processor Shutting Down. Partition '{context.PartitionId}', Reason: '{reason}'.");
|
||||
return Task.CompletedTask;
|
||||
}
|
||||
|
||||
public Task OpenAsync(PartitionContext context)
|
||||
{
|
||||
Console.WriteLine($"SimpleEventProcessor initialized. Partition: '{context.PartitionId}'");
|
||||
return Task.CompletedTask;
|
||||
}
|
||||
|
||||
public Task ProcessErrorAsync(PartitionContext context, Exception error)
|
||||
{
|
||||
Console.WriteLine($"Error on Partition: {context.PartitionId}, Error: {error.Message}");
|
||||
return Task.CompletedTask;
|
||||
}
|
||||
|
||||
public Task ProcessEventsAsync(PartitionContext context, IEnumerable<EventData> messages)
|
||||
{
|
||||
foreach (var eventData in messages)
|
||||
{
|
||||
var data = Encoding.UTF8.GetString(eventData.Body.Array, eventData.Body.Offset, eventData.Body.Count);
|
||||
Console.WriteLine($"Message received. Partition: '{context.PartitionId}', Data: '{data}'");
|
||||
}
|
||||
|
||||
return context.CheckpointAsync();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -1,30 +0,0 @@
|
|||
{
|
||||
"version": "1.0.0",
|
||||
"buildOptions": {
|
||||
"emitEntryPoint": true
|
||||
},
|
||||
|
||||
"dependencies": {
|
||||
"Microsoft.Azure.EventHubs.Processor": {
|
||||
"target": "project"
|
||||
},
|
||||
"Microsoft.Azure.EventHubs": {
|
||||
"target": "project"
|
||||
}
|
||||
},
|
||||
|
||||
"frameworks": {
|
||||
"netcoreapp1.0": {
|
||||
"dependencies": {
|
||||
"Microsoft.NETCore.App": {
|
||||
"type": "platform",
|
||||
"version": "1.0.0"
|
||||
}
|
||||
},
|
||||
"imports": [
|
||||
"dnxcore50",
|
||||
"portable-net45+win8"
|
||||
]
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -1,190 +0,0 @@
|
|||
# Get started receiving messages with the EventProcessorHost in .NET Standard
|
||||
|
||||
## What will be accomplished
|
||||
|
||||
This tutorial shows how to create the existing solution **SampleEphReceiver** (inside this folder). You can run the solution as-is, replacing the `EhConnectionString`, `EhEntityPath`, and `StorageAccount` strings with your Event Hub and storage account values, or follow this tutorial to create your own.
|
||||
|
||||
In this tutorial, we will write a .NET Core console application to receive messages from an Event Hub using the **EventProcessorHost**.
|
||||
|
||||
## Prerequisites
|
||||
|
||||
1. [Visual Studio 2015](http://www.visualstudio.com).
|
||||
|
||||
2. [.NET Core Visual Studio 2015 Tooling](http://www.microsoft.com/net/core).
|
||||
|
||||
3. An Azure subscription.
|
||||
|
||||
4. An Event Hubs namespace.
|
||||
|
||||
## Receive messages from the Event Hub
|
||||
|
||||
### Create a console application
|
||||
|
||||
1. Launch Visual Studio and create a new .NET Core console application.
|
||||
|
||||
### Add the Event Hubs NuGet package
|
||||
|
||||
* Add the following NuGet packages to your project:
|
||||
* [`Microsoft.Azure.EventHubs`](https://www.nuget.org/packages/Microsoft.Azure.EventHubs/)
|
||||
* [`Microsoft.Azure.EventHubs.Processor`](https://www.nuget.org/packages/Microsoft.Azure.EventHubs.Processor/)
|
||||
|
||||
### Implement the IEventProcessor interface
|
||||
|
||||
1. Create a new class called `SimpleEventProcessor'.
|
||||
|
||||
2. Add the following `using` statements to the top of the SimpleEventProcessor.cs file.
|
||||
|
||||
```cs
|
||||
using Microsoft.Azure.EventHubs;
|
||||
using Microsoft.Azure.EventHubs.Processor;
|
||||
```
|
||||
|
||||
3. Implement the `IEventProcessor` interface. The class should look like this:
|
||||
|
||||
```cs
|
||||
namespace SampleEphReceiver
|
||||
{
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Text;
|
||||
using System.Threading.Tasks;
|
||||
using Microsoft.Azure.EventHubs;
|
||||
using Microsoft.Azure.EventHubs.Processor;
|
||||
|
||||
public class SimpleEventProcessor : IEventProcessor
|
||||
{
|
||||
public Task CloseAsync(PartitionContext context, CloseReason reason)
|
||||
{
|
||||
Console.WriteLine($"Processor Shutting Down. Partition '{context.PartitionId}', Reason: '{reason}'.");
|
||||
return Task.CompletedTask;
|
||||
}
|
||||
|
||||
public Task OpenAsync(PartitionContext context)
|
||||
{
|
||||
Console.WriteLine($"SimpleEventProcessor initialized. Partition: '{context.PartitionId}'");
|
||||
return Task.CompletedTask;
|
||||
}
|
||||
|
||||
public Task ProcessErrorAsync(PartitionContext context, Exception error)
|
||||
{
|
||||
Console.WriteLine($"Error on Partition: {context.PartitionId}, Error: {error.Message}");
|
||||
return Task.CompletedTask;
|
||||
}
|
||||
|
||||
public Task ProcessEventsAsync(PartitionContext context, IEnumerable<EventData> messages)
|
||||
{
|
||||
foreach (var eventData in messages)
|
||||
{
|
||||
var data = Encoding.UTF8.GetString(eventData.Body.Array, eventData.Body.Offset, eventData.Body.Count);
|
||||
Console.WriteLine($"Message received. Partition: '{context.PartitionId}', Data: '{data}'");
|
||||
}
|
||||
|
||||
return context.CheckpointAsync();
|
||||
}
|
||||
}
|
||||
}
|
||||
```
|
||||
|
||||
### Write a main console method that uses `SimpleEventProcessor` to receive messages from an Event Hub
|
||||
|
||||
1. Add the following `using` statements to the top of the Program.cs file.
|
||||
|
||||
```cs
|
||||
using Microsoft.Azure.EventHubs;
|
||||
using Microsoft.Azure.EventHubs.Processor;
|
||||
```
|
||||
|
||||
2. Add constants to the `Program` class for the Event Hubs connection string, Event Hub path, storage container name, storage account name, and storage account key. Replace placeholders with their corresponding values.
|
||||
|
||||
```cs
|
||||
private const string EhConnectionString = "{Event Hubs connection string}";
|
||||
private const string EhEntityPath = "{Event Hub path/name}";
|
||||
private const string StorageContainerName = "{Storage account container name}";
|
||||
private const string StorageAccountName = "{Storage account name}";
|
||||
private const string StorageAccountKey = "{Storage account key}";
|
||||
|
||||
private static readonly string StorageConnectionString = string.Format("DefaultEndpointsProtocol=https;AccountName={0};AccountKey={1}", StorageAccountName, StorageAccountKey);
|
||||
```
|
||||
|
||||
3. Add a new method named `MainAsync` to the `Program` class like the following:
|
||||
```cs
|
||||
private static async Task MainAsync(string[] args)
|
||||
{
|
||||
Console.WriteLine("Registering EventProcessor...");
|
||||
|
||||
var eventProcessorHost = new EventProcessorHost(
|
||||
EhEntityPath,
|
||||
PartitionReceiver.DefaultConsumerGroupName,
|
||||
EhConnectionString,
|
||||
StorageConnectionString,
|
||||
StorageContainerName);
|
||||
|
||||
// Registers the Event Processor Host and starts receiving messages
|
||||
await eventProcessorHost.RegisterEventProcessorAsync<SimpleEventProcessor>();
|
||||
|
||||
Console.WriteLine("Receiving. Press enter key to stop worker.");
|
||||
Console.ReadLine();
|
||||
|
||||
// Disposes of the Event Processor Host
|
||||
await eventProcessorHost.UnregisterEventProcessorAsync();
|
||||
}
|
||||
```
|
||||
|
||||
3. Add the following line of code to the `Main` method:
|
||||
|
||||
```cs
|
||||
MainAsync(args).GetAwaiter().GetResult();
|
||||
```
|
||||
|
||||
Here is what your Program.cs file should look like:
|
||||
|
||||
```cs
|
||||
namespace SampleEphReceiver
|
||||
{
|
||||
using System;
|
||||
using System.Threading.Tasks;
|
||||
using Microsoft.Azure.EventHubs;
|
||||
using Microsoft.Azure.EventHubs.Processor;
|
||||
|
||||
public class Program
|
||||
{
|
||||
private const string EhConnectionString = "{Event Hubs connection string}";
|
||||
private const string EhEntityPath = "{Event Hub path/name}";
|
||||
private const string StorageContainerName = "{Storage account container name}";
|
||||
private const string StorageAccountName = "{Storage account name}";
|
||||
private const string StorageAccountKey = "{Storage account key}";
|
||||
|
||||
private static readonly string StorageConnectionString = string.Format("DefaultEndpointsProtocol=https;AccountName={0};AccountKey={1}", StorageAccountName, StorageAccountKey);
|
||||
|
||||
public static void Main(string[] args)
|
||||
{
|
||||
MainAsync(args).GetAwaiter().GetResult();
|
||||
}
|
||||
|
||||
private static async Task MainAsync(string[] args)
|
||||
{
|
||||
Console.WriteLine("Registering EventProcessor...");
|
||||
|
||||
var eventProcessorHost = new EventProcessorHost(
|
||||
EhEntityPath,
|
||||
PartitionReceiver.DefaultConsumerGroupName,
|
||||
EhConnectionString,
|
||||
StorageConnectionString,
|
||||
StorageContainerName);
|
||||
|
||||
// Registers the Event Processor Host and starts receiving messages
|
||||
await eventProcessorHost.RegisterEventProcessorAsync<SimpleEventProcessor>();
|
||||
|
||||
Console.WriteLine("Receiving. Press enter key to stop worker.");
|
||||
Console.ReadLine();
|
||||
|
||||
// Disposes of the Event Processor Host
|
||||
await eventProcessorHost.UnregisterEventProcessorAsync();
|
||||
}
|
||||
}
|
||||
}
|
||||
```
|
||||
|
||||
4. Run the program, and ensure that there are no errors.
|
||||
|
||||
Congratulations! You have now received messages from an Event Hub.
|
||||
|
|
@ -1,64 +0,0 @@
|
|||
// Copyright (c) Microsoft. All rights reserved.
|
||||
// Licensed under the MIT license. See LICENSE file in the project root for full license information.
|
||||
|
||||
namespace SampleSender
|
||||
{
|
||||
using System;
|
||||
using System.Text;
|
||||
using System.Threading.Tasks;
|
||||
using Microsoft.Azure.EventHubs;
|
||||
|
||||
public class Program
|
||||
{
|
||||
private static EventHubClient eventHubClient;
|
||||
private const string EhConnectionString = "{Event Hubs connection string}";
|
||||
private const string EhEntityPath = "{Event Hub path/name}";
|
||||
|
||||
public static void Main(string[] args)
|
||||
{
|
||||
MainAsync(args).GetAwaiter().GetResult();
|
||||
}
|
||||
|
||||
private static async Task MainAsync(string[] args)
|
||||
{
|
||||
// Creates an EventHubsConnectionStringBuilder object from a the connection string, and sets the EntityPath.
|
||||
// Typically the connection string should have the Entity Path in it, but for the sake of this simple scenario
|
||||
// we are using the connection string from the namespace.
|
||||
var connectionStringBuilder = new EventHubsConnectionStringBuilder(EhConnectionString)
|
||||
{
|
||||
EntityPath = EhEntityPath
|
||||
};
|
||||
|
||||
eventHubClient = EventHubClient.CreateFromConnectionString(connectionStringBuilder.ToString());
|
||||
|
||||
await SendMessagesToEventHub(100);
|
||||
|
||||
await eventHubClient.CloseAsync();
|
||||
|
||||
Console.WriteLine("Press any key to exit.");
|
||||
Console.ReadLine();
|
||||
}
|
||||
|
||||
// Creates an Event Hub client and sends 100 messages to the event hub.
|
||||
private static async Task SendMessagesToEventHub(int numMessagesToSend)
|
||||
{
|
||||
for (var i = 0; i < numMessagesToSend; i++)
|
||||
{
|
||||
try
|
||||
{
|
||||
var message = $"Message {i}";
|
||||
Console.WriteLine($"Sending message: {message}");
|
||||
await eventHubClient.SendAsync(new EventData(Encoding.UTF8.GetBytes(message)));
|
||||
}
|
||||
catch (Exception exception)
|
||||
{
|
||||
Console.WriteLine($"{DateTime.Now} > Exception: {exception.Message}");
|
||||
}
|
||||
|
||||
await Task.Delay(10);
|
||||
}
|
||||
|
||||
Console.WriteLine($"{numMessagesToSend} messages sent.");
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -1,21 +0,0 @@
|
|||
// Copyright (c) Microsoft. All rights reserved.
|
||||
// Licensed under the MIT license. See LICENSE file in the project root for full license information.
|
||||
|
||||
using System.Reflection;
|
||||
using System.Runtime.InteropServices;
|
||||
|
||||
// General Information about an assembly is controlled through the following
|
||||
// set of attributes. Change these attribute values to modify the information
|
||||
// associated with an assembly.
|
||||
[assembly: AssemblyConfiguration("")]
|
||||
[assembly: AssemblyCompany("")]
|
||||
[assembly: AssemblyProduct("SampleSender")]
|
||||
[assembly: AssemblyTrademark("")]
|
||||
|
||||
// Setting ComVisible to false makes the types in this assembly not visible
|
||||
// to COM components. If you need to access a type in this assembly from
|
||||
// COM, set the ComVisible attribute to true on that type.
|
||||
[assembly: ComVisible(false)]
|
||||
|
||||
// The following GUID is for the ID of the typelib if this project is exposed to COM
|
||||
[assembly: Guid("940bca4a-b154-4667-8a03-57e6b689866d")]
|
||||
|
|
@ -1,19 +0,0 @@
|
|||
<?xml version="1.0" encoding="utf-8"?>
|
||||
<Project ToolsVersion="14.0" DefaultTargets="Build" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
|
||||
<PropertyGroup>
|
||||
<VisualStudioVersion Condition="'$(VisualStudioVersion)' == ''">14.0</VisualStudioVersion>
|
||||
<VSToolsPath Condition="'$(VSToolsPath)' == ''">$(MSBuildExtensionsPath32)\Microsoft\VisualStudio\v$(VisualStudioVersion)</VSToolsPath>
|
||||
</PropertyGroup>
|
||||
<Import Project="$(VSToolsPath)\DotNet\Microsoft.DotNet.Props" Condition="'$(VSToolsPath)' != ''" />
|
||||
<PropertyGroup Label="Globals">
|
||||
<ProjectGuid>940bca4a-b154-4667-8a03-57e6b689866d</ProjectGuid>
|
||||
<RootNamespace>SampleSender</RootNamespace>
|
||||
<BaseIntermediateOutputPath Condition="'$(BaseIntermediateOutputPath)'=='' ">.\obj\</BaseIntermediateOutputPath>
|
||||
<OutputPath Condition="'$(OutputPath)'=='' ">.\bin\</OutputPath>
|
||||
<TargetFrameworkVersion>v4.5.2</TargetFrameworkVersion>
|
||||
</PropertyGroup>
|
||||
<PropertyGroup>
|
||||
<SchemaVersion>2.0</SchemaVersion>
|
||||
</PropertyGroup>
|
||||
<Import Project="$(VSToolsPath)\DotNet\Microsoft.DotNet.targets" Condition="'$(VSToolsPath)' != ''" />
|
||||
</Project>
|
||||
|
|
@ -1,22 +0,0 @@
|
|||
{
|
||||
"version": "1.0.0",
|
||||
"buildOptions": {
|
||||
"emitEntryPoint": true
|
||||
},
|
||||
|
||||
"dependencies": {
|
||||
"Microsoft.Azure.EventHubs": {
|
||||
"target": "project"
|
||||
},
|
||||
"Microsoft.NETCore.App": {
|
||||
"type": "platform",
|
||||
"version": "1.0.1"
|
||||
}
|
||||
},
|
||||
|
||||
"frameworks": {
|
||||
"netcoreapp1.0": {
|
||||
"imports": "dnxcore50"
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -1,171 +0,0 @@
|
|||
# Get started sending messages to Event Hubs in .NET Standard
|
||||
|
||||
## What will be accomplished
|
||||
|
||||
This tutorial shows how to create the existing solution **SampleSender** (inside this folder). You can run the solution as-is, replacing the `EhConnectionString`, `EhEntityPath`, and `StorageAccount` strings with your Event Hub values, or follow this tutorial to create your own.
|
||||
|
||||
In this tutorial, we will write a .NET Core console application to send messages to an Event Hub.
|
||||
|
||||
## Prerequisites
|
||||
|
||||
1. [Visual Studio 2015](http://www.visualstudio.com).
|
||||
|
||||
2. [.NET Core Visual Studio 2015 Tooling](http://www.microsoft.com/net/core).
|
||||
|
||||
3. An Azure subscription.
|
||||
|
||||
4. An Event Hubs namespace.
|
||||
|
||||
## Send messages to an Event Hub
|
||||
|
||||
To send messages to an Event Hub, we will write a C# console application using Visual Studio.
|
||||
|
||||
### Create a console application
|
||||
|
||||
* Launch Visual Studio and create a new .NET Core console application.
|
||||
|
||||
### Add the Event Hubs NuGet package
|
||||
|
||||
* Add the [`Microsoft.Azure.EventHubs`](https://www.nuget.org/packages/Microsoft.Azure.EventHubs/) NuGet package to your project.
|
||||
|
||||
### Write some code to send messages to the Event Hub
|
||||
|
||||
1. Add the following `using` statement to the top of the Program.cs file.
|
||||
|
||||
```cs
|
||||
using Microsoft.Azure.EventHubs;
|
||||
```
|
||||
|
||||
2. Add constants to the `Program` class for the Event Hubs connection string and entity path (individual Event Hub name). Replace the placeholders in brackets with the proper values that were obtained when creating the Event Hub.
|
||||
|
||||
```cs
|
||||
private static EventHubClient eventHubClient;
|
||||
private const string EhConnectionString = "{Event Hubs connection string}";
|
||||
private const string EhEntityPath = "{Event Hub path/name}";
|
||||
```
|
||||
|
||||
3. Add a new method named `MainAsync` to the `Program` class like the following:
|
||||
|
||||
```cs
|
||||
private static async Task MainAsync(string[] args)
|
||||
{
|
||||
// Creates an EventHubsConnectionStringBuilder object from a the connection string, and sets the EntityPath.
|
||||
// Typically the connection string should have the Entity Path in it, but for the sake of this simple scenario
|
||||
// we are using the connection string from the namespace.
|
||||
var connectionStringBuilder = new EventHubsConnectionStringBuilder(EhConnectionString)
|
||||
{
|
||||
EntityPath = EhEntityPath
|
||||
};
|
||||
|
||||
eventHubClient = EventHubClient.CreateFromConnectionString(connectionStringBuilder.ToString());
|
||||
|
||||
await SendMessagesToEventHub(100);
|
||||
|
||||
await eventHubClient.CloseAsync();
|
||||
|
||||
Console.WriteLine("Press any key to exit.");
|
||||
Console.ReadLine();
|
||||
}
|
||||
```
|
||||
|
||||
4. Add a new method named `SendMessagesToEventHub` to the `Program` class like the following:
|
||||
|
||||
```cs
|
||||
// Creates an Event Hub client and sends 100 messages to the event hub.
|
||||
private static async Task SendMessagesToEventHub(int numMessagesToSend)
|
||||
{
|
||||
for (var i = 0; i < numMessagesToSend; i++)
|
||||
{
|
||||
try
|
||||
{
|
||||
var message = $"Message {i}";
|
||||
Console.WriteLine($"Sending message: {message}");
|
||||
await eventHubClient.SendAsync(new EventData(Encoding.UTF8.GetBytes(message)));
|
||||
}
|
||||
catch (Exception exception)
|
||||
{
|
||||
Console.WriteLine($"{DateTime.Now} > Exception: {exception.Message}");
|
||||
}
|
||||
|
||||
await Task.Delay(10);
|
||||
}
|
||||
|
||||
Console.WriteLine($"{numMessagesToSend} messages sent.");
|
||||
}
|
||||
```
|
||||
|
||||
5. Add the following code to the `Main` method in the `Program` class.
|
||||
|
||||
```cs
|
||||
MainAsync(args).GetAwaiter().GetResult();
|
||||
```
|
||||
|
||||
Here is what your Program.cs should look like.
|
||||
|
||||
```cs
|
||||
namespace SampleSender
|
||||
{
|
||||
using System;
|
||||
using System.Text;
|
||||
using System.Threading.Tasks;
|
||||
using Microsoft.Azure.EventHubs;
|
||||
|
||||
public class Program
|
||||
{
|
||||
private static EventHubClient eventHubClient;
|
||||
private const string EhConnectionString = "{Event Hubs connection string}";
|
||||
private const string EhEntityPath = "{Event Hub path/name}";
|
||||
|
||||
public static void Main(string[] args)
|
||||
{
|
||||
MainAsync(args).GetAwaiter().GetResult();
|
||||
}
|
||||
|
||||
private static async Task MainAsync(string[] args)
|
||||
{
|
||||
// Creates an EventHubsConnectionStringBuilder object from a the connection string, and sets the EntityPath.
|
||||
// Typically the connection string should have the Entity Path in it, but for the sake of this simple scenario
|
||||
// we are using the connection string from the namespace.
|
||||
var connectionStringBuilder = new EventHubsConnectionStringBuilder(EhConnectionString)
|
||||
{
|
||||
EntityPath = EhEntityPath
|
||||
};
|
||||
|
||||
eventHubClient = EventHubClient.CreateFromConnectionString(connectionStringBuilder.ToString());
|
||||
|
||||
await SendMessagesToEventHub(100);
|
||||
|
||||
await eventHubClient.CloseAsync();
|
||||
|
||||
Console.WriteLine("Press any key to exit.");
|
||||
Console.ReadLine();
|
||||
}
|
||||
|
||||
// Creates an Event Hub client and sends 100 messages to the event hub.
|
||||
private static async Task SendMessagesToEventHub(int numMessagesToSend)
|
||||
{
|
||||
for (var i = 0; i < numMessagesToSend; i++)
|
||||
{
|
||||
try
|
||||
{
|
||||
var message = $"Message {i}";
|
||||
Console.WriteLine($"Sending message: {message}");
|
||||
await eventHubClient.SendAsync(new EventData(Encoding.UTF8.GetBytes(message)));
|
||||
}
|
||||
catch (Exception exception)
|
||||
{
|
||||
Console.WriteLine($"{DateTime.Now} > Exception: {exception.Message}");
|
||||
}
|
||||
|
||||
await Task.Delay(10);
|
||||
}
|
||||
|
||||
Console.WriteLine($"{numMessagesToSend} messages sent.");
|
||||
}
|
||||
}
|
||||
}
|
||||
```
|
||||
|
||||
6. Run the program, and ensure that there are no errors thrown.
|
||||
|
||||
Congratulations! You have now sent messages to an Event Hub.
|
||||
Загрузка…
Ссылка в новой задаче