Любой пример WebJob с использованием EventHub?

Question

Я пытался придумать что-то из примера в WebJobsSDK GitHub

var eventHubConfig = new EventHubConfiguration(); 
string eventHubName = "MyHubName"; 
eventHubConfig.AddSender(eventHubName,"Endpoint=sb://test.servicebus.windows.net/;SharedAccessKeyName=SendRule;SharedAccessKey=xxxxxxxx"); 
eventHubConfig.AddReceiver(eventHubName, "Endpoint=sb://test.servicebus.windows.net/;SharedAccessKeyName=ReceiveRule;SharedAccessKey=yyyyyyy"); 

config.UseEventHub(eventHubConfig); 
JobHost host = new JobHost(config); 

Но я боюсь, что это не достаточно далеко для кого-то из моих ограниченных «» навыков!

• Я не могу найти ни одного примера JobHostConfiguration, который имеет свойство UseEventHub (используя версию пакета Microsoft.AzureWebJobs v1.2.0-альфа-10291), поэтому я не могу передать EventHubConfiguration в JobHost.

• Я использовал EventHub раньше, а не в контексте WebJob. Я не вижу, требуется ли EventHostProcessor, если вы используете запуск WebJob ... или запускает ли запуск WebJob как EventHostProcessor?

В любом случае, если у кого-то есть более полный пример для простака, подобного мне, это было бы действительно мило! Спасибо

Answer 1

Из документации here, вы должны иметь всю необходимую Вам информацию.

Что вам не хватает, это ссылка на пакет nuget Microsoft.Azure.WebJobs.ServiceBus.1.2.0-alpha-10291.

UseEventHub - это метод расширения, объявленный в этом пакете.

В противном случае ваша конфигурация выглядит нормально. Вот пример того, как получить или отправлять сообщения от/до EventHub:

public class BasicTest 
{ 
    public class Payload 
    { 
     public int Counter { get; set; } 
    } 
    public static void SendEvents([EventHub("MyHubName")] out Payload x) 
    { 
     x = new Payload { Counter = 100 }; 
    } 

    public static void Trigger(
     [EventHubTrigger("MyHubName")] Payload x, 
     [EventHub("MyHubName")] out Payload y) 
    { 
     x.Counter++; 
     y = x; 
    } 
} 

Answer 2

EventProcessorHost по-прежнему требуется, так как WebJob предоставляет только среду хостинга для ее запуска. Насколько я знаю, EventProcessorHost не так глубоко интегрирован в WebJob, поэтому его механизм запуска не может использоваться для обработки сообщений EventHub. Я использую WebJob для запуска EventProcessorHost непрерывно:

public static void Main() 
{ 
    RunAsync().Wait(); 
} 

private static async Task RunAsync() 
{ 
    try 
    { 
     using (var shutdownWatcher = new WebJobsShutdownWatcher()) 
     { 
      await Console.Out.WriteLineAsync("Initializing..."); 

      var eventProcessorHostName = "eventProcessorHostName"; 
      var eventHubName = ConfigurationManager.AppSettings["eventHubName"]; 
      var consumerGroupName = ConfigurationManager.AppSettings["eventHubConsumerGroupName"]; 
      var eventHubConnectionString = ConfigurationManager.ConnectionStrings["EventHub"].ConnectionString; 
      var storageConnectionString = ConfigurationManager.ConnectionStrings["EventHubStorage"].ConnectionString; 

      var eventProcessorHost = new EventProcessorHost(eventProcessorHostName, eventHubName, consumerGroupName, eventHubConnectionString, storageConnectionString); 

      await Console.Out.WriteLineAsync("Registering event processors..."); 

      var processorOptions = new EventProcessorOptions(); 

      processorOptions.ExceptionReceived += ProcessorOptions_ExceptionReceived; 

      await eventProcessorHost.RegisterEventProcessorAsync<CustomEventProcessor>(processorOptions); 

      await Console.Out.WriteLineAsync("Processing..."); 

      await Task.Delay(Timeout.Infinite, shutdownWatcher.Token); 

      await Console.Out.WriteLineAsync("Unregistering event processors..."); 

      await eventProcessorHost.UnregisterEventProcessorAsync(); 

      await Console.Out.WriteLineAsync("Finished."); 
     } 
     catch (Exception ex) 
     { 
      await HandleErrorAsync(ex); 
     } 
    } 
} 

private static async void ProcessorOptions_ExceptionReceived(object sender, ExceptionReceivedEventArgs e) 
{ 
    await HandleErrorAsync(e.Exception); 
} 

private static async Task HandleErrorAsync(Exception ex) 
{ 
    await Console.Error.WriteLineAsync($"Critical error occured: {ex.Message}{ex.StackTrace}"); 
}