2017-03-22 6 views
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; } 
} 

답변

0

은 내가 아는 한, 당신은 EventHubTrigger 방법에 매개 변수로 설정할 수 있습니다.

public static async Task ProcessQueueMessage([EventHubTrigger("Yourhubname", ConsumerGroup = "groupname")] string[] messages, TextWriter log) 
    { 
     ... 
    } 
:

자세한 내용은, 당신은 코드를 따라 참조 할 수