azure 事件网格 - 使用 azure 存储队列作为端点类型创建订阅

Question

我们可以使用 Azure CLI 通过存储队列订阅事件网格主题，如上所述:

az eventgrid event-subscription create \
  --topic-name demotopic \
  -g myResourceGroup \
  --name eventsub1 \
  --endpoint-type storagequeue \
  --endpoint <storage-queue-url>

使用 Microsoft.Azure.Management.EventGrid 时:

EventSubscription eventSubscription = new EventSubscription()
    {
        Destination = new WebHookEventSubscriptionDestination()
        {
             EndpointUrl = endpointUrl
        },
        // The below are all optional settings
        EventDeliverySchema = EventDeliverySchema.EventGridSchema,
        Filter = new EventSubscriptionFilter()
        {
             // By default, "All" event types are included
             IsSubjectCaseSensitive = false,
             SubjectBeginsWith = "",
             SubjectEndsWith = ""
        }

   };

我没有获得任何属性或方法来设置 CLI 命令中提到的端点类型和端点。

任何人都可以帮助我如何使用 C# nuget 库将端点类型设置为 storagequeue

Answer 1

您应该使用以下类:

    [JsonObject("StorageQueue"), JsonTransformation]
    public class StorageQueueEventSubscriptionDestination : EventSubscriptionDestination
    {
        // Methods
        public StorageQueueEventSubscriptionDestination();
        public StorageQueueEventSubscriptionDestination(string resourceId = new string(), string queueName = new string());

        // Properties
        [JsonProperty(PropertyName="properties.queueName")]
        public string QueueName { get; set; }
        [JsonProperty(PropertyName="properties.resourceId")]
        public string ResourceId { get; set; }
    }

来自Microsoft.Azure.Management.EventGrid 2.0.0-预览版

此外，在此预览中可以填充“DeadLetterDestination”和“RetryPolicy”属性。

对于 DeadLetterDestination 使用以下类:

    [JsonObject("StorageBlob"), JsonTransformation]
    public class StorageBlobDeadLetterDestination : DeadLetterDestination
    {
        // Methods
        public StorageBlobDeadLetterDestination();
        public StorageBlobDeadLetterDestination(string resourceId = new string(), string blobContainerName = new string());

        // Properties
        [JsonProperty(PropertyName="properties.blobContainerName")]
        public string BlobContainerName { get; set; }
        [JsonProperty(PropertyName="properties.resourceId")]
        public string ResourceId { get; set; }
    }