首页 > 解决方案 > 使用 Kudu API 将带有 serviceBusTrigger 的 azure 函数部署到现有函数应用程序,即使在手动同步触发器后也不会触发

问题描述

我有一个现有的函数应用程序,我需要在应用程序中的用户操作后部署 serviceBusTrigger 函数。为此,我一直在使用以下帖子Deploy Azure function from code (c#)

此函数应用的 Azure 函数版本 2.0

我目前正在创建一个包含 /function.json 的 zip,该 zip 使用以下方法发布到 api/zip 端点

public void CreateAzureFunctionToMonitorQueue(string functionName, string serviceBusQueueName, string path)
    {
        // create zip of new function
        // ZipFile.CreateFromDirectory will create a zip with the directory's name containing the directory's contents
        // so CreateZipOfFunc creates a structure <functionName>/<functionName>/function.json
        // so that the zip contains <functionName>/function.json 
        // which is the required input for api/zip/ from kudu api
        var zipFile = CreateZipOfFunc(functionName, serviceBusQueueName, path);
        var file = File.ReadAllBytes(zipFile);

        MemoryStream stream = new MemoryStream(file);

        using (var client = new HttpClient())
        {
            // deploy zip using Kudu REST api
            client.DefaultRequestHeaders.Add("Authorization", "Basic " + _base64Auth);
            var baseUrl = new Uri($"https://{_webFunctionAppName}.scm.azurewebsites.net/");
            var requestURl = baseUrl + "api/zip/site/wwwroot";
            var httpContent = new StreamContent(stream);
            var response = client.PutAsync(requestURl, httpContent).Result;
        }
        // remove files
        Directory.Delete($"{path}{functionName}", true);
        File.Delete($"{path}{functionName}.zip");
        // deployment using Kudu REST api requires the function triggers to be manually synced
        SyncTriggers();
    }

最后,我运行 SyncTriggers 手动同步函数应用程序的触发器,因为我读到以这种方式部署需要对除 http 之外的所有触发器进行此操作,可在此处找到https://docs.microsoft.com/en-us/azure/azure-functions /功能-部署-技术。我正在使用手动同步触发器的第二种方法。下面是方法

public void SyncTriggers()
    {
        using (var client = new HttpClient())
        {
            var requestUrl = $"https://{_webFunctionAppName}.azurewebsites.net/admin/host/synctriggers?code={_MASTER_KEY}";
            var httpContent = new StringContent("");
            var response = client.PostAsync(requestUrl, httpContent).Result;
        }
    }

两个请求的结果都是成功的,当我查看 azure 门户时,使用 Visual Studio webdeploy 部署时,新函数带有一个与工作 serviceBusTrigger 匹配的 function.json 文件。

为了测试这一点,我首先禁用了工作 azure 功能,运行上面的代码,然后将新消息推送到受监控的队列;但是,当消息变为活动状态时,什么也不会发生。

如果我启用使用已存在的 VS 部署的功能,该功能将触发并处理该消息。

现有函数的 function.json 文件如下所示

{
  "generatedBy": "Microsoft.NET.Sdk.Functions-1.0.26",
  "configurationSource": "attributes",
  "bindings": [
    {
      "type": "serviceBusTrigger",
      "connection": "ServiceBusConnection",
      "queueName": "myqueue",
      "name": "queueItem"
    }
  ],
  "disabled": false,
  "scriptFile": "../bin/MyProject.MyLibrary.dll",
  "entryPoint": "MyProject.MyLibrary.MyClass.RunAsync"
}

使用上述方法部署的函数有一个如下的function.json

{
  "generatedBy": "Microsoft.NET.Sdk.Functions - 1.0.26",
  "configurationSource": "attributes",
  "bindings": [
    {
      "type": "serviceBusTrigger",
      "connection": "ServiceBusConnection",
      "queueName": "myqueue",
      "name": "queueItem"
    }
  ],
  "disabled": false,
  "scriptFile": "../bin/MyProject.MyLibrary.dll",
  "entryPoint": "MyProject.MyLibrary.MyClass.RunAsync"
}

我错过了什么吗?我的用例是,在我创建一个新队列后,我想创建一个监视 azure 函数来监听它。使用 NameSpaceManager 创建队列工作正常,向其推送消息也工作正常。我似乎无法让这个测试用例在我创建一个函数来监控现有队列的地方工作。

当我调用 SyncTrigger 时,该功能可能没有注册和正确设置?

谢谢

编辑:我刚刚看到这篇文章https://blogs.msdn.microsoft.com/benjaminperkins/2018/08/07/why-does-my-azure-function-sometimes-stop-being-triggered/ 它说:

Your endpoint must trigger/bind to only one Azure Function

这是否意味着我只能将一个函数注册到我上传的 dll 中的一个函数?我是否应该使用 function.json 文件上传我想要的具有不同名称的入口点方法的副本作为 .csx 文件?

Edit2:这似乎只是与 az fns 绑定资源有关,似乎没有帮助

Edit3:经过大量研究,我生成的function.json的configurationSource似乎不应该是“属性”,而是“配置”。现在要测试这个。

Edit4:通过在我正在生成的 function.json 文件中删除 generateBy 并将 configurationSource 更改为“config”来解决该问题。

Edit5:删除了误导性问题

标签: azureazure-functionsazureservicebusazure-servicebus-queues

解决方案


问题是使用 VS 部署的函数在 function.json 中有两个属性

"generatedBy": "Microsoft.NET.Sdk.Functions - 1.0.26",
"configurationSource": "attributes",

这实际上只是告诉 azure 从哪里生成函数,并使用作为函数入口点的方法的属性作为配置源。删除 generateBy 允许在 azure 门户中编辑函数并将 configurationSource 更改为“config”告诉 azure 函数运行时使用 function.json 文件进行绑定配置,什么不是。

但是,在天蓝色的门户中,我收到一条消息

Error:

Function (MyFunction) Error: Configuration error: all functions in D:\home\site\wwwroot\bin\MyProject.MyLibrary.dll must have the same value for 'configurationSource'.
Session Id: MY_SESSION_ID

Timestamp: 2019-06-30T21:04:22.709Z

我部署的函数仍然有效,其他现有的具有已部署函数调用的 http 绑定的函数仍然有效(它们具有由 Skd.Functions 和 configurationSource 生成的 function.json 文件:“attributes”,所以这似乎不是目前是成败错误;但是,我将更改我的部署,以便所有人都有 configurationSource:“config”

所以将输出 function.json 更改为

{
  "configurationSource": "config",
  "bindings": [
    {
      "type": "serviceBusTrigger",
      "connection": "ServiceBusConnection",
      "queueName": "myqueue",
      "name": "queueItem"
    }
  ],
  "disabled": false,
  "scriptFile": "../bin/MyProject.MyLibrary.dll",
  "entryPoint": "MyProject.MyLibrary.MyClass.RunAsync"
}

解决了我的问题


推荐阅读