0

我已经定义了这个函数：

[FunctionName("My_QueueTrigger")]
public Task RunAsync([QueueTrigger("my-queue-name", Connection = "AzureWebJobsStorage")] string text)
{
  // code here...
}

并且AzureWebJobsStorage（在 Azure 上）包含以下内容："DefaultEndpointsProtocol=https;AccountName=my-storage-account;AccountKey=mykey;EndpointSuffix=core.windows.net"

（请注意，对于本地开发，该值为"UseDevelopmentStorage=true"。）

我的问题是，也可以在这里定义存储帐户名称，"https://my-storage-account.queue.core.windows.net"并使用 Azure 函数中的托管标识（具有处理器权限）来读取/触发消息。

4

1 回答 1

0

我认为你的要求是不可能的。

连接Storage的底层代码已经封装在WebJob包中，作为成员包包含在整个功能的扩展包中。您必须修改底层代码才能实现您想要的功能。

查看 queuetrigger 属性的源码：

using System;
using System.Diagnostics;
using Microsoft.Azure.WebJobs.Description;

namespace Microsoft.Azure.WebJobs
{
    /// <summary>
    /// Attribute used to bind a parameter to an Azure Queue message, causing the function to run when a
    /// message is enqueued.
    /// </summary>
    /// <remarks>
    /// The method parameter type can be one of the following:
    /// <list type="bullet">
    /// <item><description>CloudQueueMessage</description></item>
    /// <item><description><see cref="string"/></description></item>
    /// <item><description><see cref="T:byte[]"/></description></item>
    /// <item><description>A user-defined type (serialized as JSON)</description></item>
    /// </list>
    /// </remarks>
    [AttributeUsage(AttributeTargets.Parameter)]
    [DebuggerDisplay("{QueueName,nq}")]
    [ConnectionProvider(typeof(StorageAccountAttribute))]
    [Binding]
    public sealed class QueueTriggerAttribute : Attribute, IConnectionProvider
    {
        private readonly string _queueName;

        /// <summary>Initializes a new instance of the <see cref="QueueTriggerAttribute"/> class.</summary>
        /// <param name="queueName">The name of the queue to which to bind.</param>
        public QueueTriggerAttribute(string queueName)
        {
            _queueName = queueName;
        }

        /// <summary>Gets the name of the queue to which to bind.</summary>
        public string QueueName
        {
            get { return _queueName; }
        }

        /// <summary>
        /// Gets or sets the app setting name that contains the Azure Storage connection string.
        /// </summary>
        public string Connection { get; set; }
    }
}

您可以找到源代码，它告诉我们需要提供连接字符串而不是存储 url。

下载webjobs包源码，查看queuetrigger源码，你会发现源码没有实现你想要的。您无法告诉该功能您要使用 MSI，它也不为您提供任何使用此功能的方法。

总之，源代码无法实现你的想法。除非修改源码的底层实现，重新编译导入包，否则是不可能的。

于 2020-10-07T06:29:08.867 回答