0
사용자 정의 ConsumerGroup과 함께 EventHubTrigger를 사용하고자합니다. 기본 ConsumerGroup를 사용하는 경우EventHubTrigger를 사용하여 사용자 정의 ConsumerGroup 구성
코드는 다음과 같습니다
public static async Task ProcessQueueMessage([EventHubTrigger("%EventHubName%")] TelemetryEvent[] messages, TextWriter log)
{}
EventHubTriggerAttribute
클래스를 설정할 수있는 ConsumerGroup 속성이 있습니다. 그러나 어떻게? 당신이 EventHubTrigger에 ConsumerGroup 속성을 설정하려면
[AttributeUsage(AttributeTargets.Parameter)]
public sealed class EventHubTriggerAttribute : Attribute
{
//
// Summary:
// Create an instance of this attribute.
//
// Parameters:
// eventHubName:
// Event hub to listen on for messages.
public EventHubTriggerAttribute(string eventHubName);
//
// Summary:
// Name of the event hub.
public string EventHubName { get; }
//
// Summary:
// Optional Name of the consumer group. If missing, then use the default name, "$Default"
public string ConsumerGroup { get; set; }
}