在逻辑应用程序中运行时Azure函数404错误

Question

我在 Azure 中构建了一个简单的函数，它从 json 正文中获取文件的位置，并读取第一行以从所述文件中获取标头。我正在 Visual Studio 中构建该函数并使用打包部署发布它。

我可以在 Azure Functions 下的门户上测试该函数并获得返回结果，但是当我在逻辑应用程序中尝试该函数时，出现 404 Not Found 错误。

我已经创建了 MS 提供的示例 HTTPRequest 函数，并且在相同的函数名称下工作正常，但我不确定为什么我编写的函数不起作用。

下面是我用于该函数的代码

using System;
using System.IO;
using System.Collections.Generic;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;

namespace Functions
{
    public static class GetTableHeaders
    {
        [FunctionName("GetTableHeaders")]
        public static async Task<IActionResult> Run(
            [HttpTrigger(AuthorizationLevel.Function, "get", "post", Route = null)] HttpRequest req,
            IBinder binder,
            ILogger log)
        {
            log.LogInformation("C# HTTP trigger function processed a request.");

            string guid = req.Query["guid"];
            string header = req.Query["header"];
            string location = req.Query["location"];
            string line = null;
            string[] headers = null;
            int size = 0;

            string requestBody = await new StreamReader(req.Body).ReadToEndAsync();
            dynamic data = JsonConvert.DeserializeObject(requestBody);
            guid = guid ?? data?.guid;
            header = header ?? data?.header;
            location = location ?? data?.location;

            if (guid != null)
            {
                location = location.Substring(1);
                using (var reader = binder.Bind<TextReader>(new BlobAttribute(
                    $"{location}", FileAccess.Read)))
                {
                    line = reader.ReadLine();
                    headers = line.Split(',');
                    size = headers.Length;
                    if (!Convert.ToBoolean(header))
                    {
                        List<string> genericheaders = new List<string>();
                        for (int i = 1; i <= size; i++)
                        {
                            genericheaders.Add($"column{i}");
                        }
                        headers = genericheaders.ToArray();
                    }

                };
                return (ActionResult)new OkObjectResult($"{string.Join("|", headers)}");
            }
            else
            {
                return (ActionResult)new BadRequestObjectResult("Please pass a name on the query string or in the request body");
            }
        }
    }
}

以下是在 MS 示例函数中运行的代码：

using System;
using System.IO;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;

namespace Functions
{
    public static class HttpFunction
    {
        [FunctionName("HttpFunction")]
        public static async Task<IActionResult> Run(
            [HttpTrigger(AuthorizationLevel.Function, "get", "post", Route = null)] HttpRequest req,
            ILogger log)
        {
            log.LogInformation("C# HTTP trigger function processed a request.");

            string name = req.Query["name"];

            string requestBody = await new StreamReader(req.Body).ReadToEndAsync();
            dynamic data = JsonConvert.DeserializeObject(requestBody);
            name = name ?? data?.name;

            return name != null
                ? (ActionResult)new OkObjectResult($"Hello, {name}")
                : new BadRequestObjectResult("Please pass a name on the query string or in the request body");
        }
    }
}

以下是我在 Azure Functions 中运行代码时的结果：

这是我尝试使用该函数运行后从逻辑应用程序收到的错误：

以下是逻辑应用 json（将订阅 ID 替换为 xxxx）

{
    "$connections": {
        "value": {
            "azureblob": {
                "connectionId": "/subscriptions/xxxx/resourceGroups/AMCDS/providers/Microsoft.Web/connections/azureblob",
                "connectionName": "azureblob",
                "id": "/subscriptions/xxxx/providers/Microsoft.Web/locations/westeurope/managedApis/azureblob"
            },
            "sql": {
                "connectionId": "/subscriptions/xxxx/resourceGroups/AMCDS/providers/Microsoft.Web/connections/sql-1",
                "connectionName": "sql-1",
                "id": "/subscriptions/xxxx/providers/Microsoft.Web/locations/westeurope/managedApis/sql"
            }
        }
    },
    "definition": {
        "$schema": "https://schema.management.azure.com/providers/Microsoft.Logic/schemas/2016-06-01/workflowdefinition.json#",
        "actions": {
            "Create_GUID": {
                "inputs": "@guid()",
                "runAfter": {},
                "type": "Compose"
            },
            "GetTableHeaders": {
                "inputs": {
                    "body": {
                        "guid": "@{outputs('Create_GUID')}",
                        "header": "@{body('Insert_row_2')?['HasHeaders']}",
                        "location": "@{triggerBody()?['Path']}"
                    },
                    "function": {
                        "id": "/subscriptions/xxxx/resourceGroups/AMCDS/providers/Microsoft.Web/sites/AMCDSFunctionsWindows/functions/GetTableHeaders"
                    },
                    "method": "POST"
                },
                "runAfter": {
                    "Insert_row_2": [
                        "Succeeded"
                    ]
                },
                "type": "Function"
            },
            "HttpFunction": {
                "inputs": {
                    "body": {
                        "name": "Nirmal"
                    },
                    "function": {
                        "id": "/subscriptions/xxxx/resourceGroups/AMCDS/providers/Microsoft.Web/sites/AMCDSFunctionsWindows/functions/HttpFunction"
                    }
                },
                "runAfter": {
                    "Insert_row_2": [
                        "Succeeded"
                    ]
                },
                "type": "Function"
            },
            "Insert_row_2": {
                "inputs": {
                    "body": {
                        "DataType": "@{outputs('Split_FileName')[3]}",
                        "DateLoaded": "@{utcNow()}",
                        "FileDate": "@{outputs('Split_FileName')[1]}",
                        "FileName": "@triggerBody()?['Name']",
                        "FilePath": "@triggerBody()?['Path']",
                        "GUID": "@{outputs('Create_GUID')}",
                        "HasHeaders": "@if(equals(outputs('Split_FileName')[2],'#Y#'),true,false)"
                    },
                    "host": {
                        "connection": {
                            "name": "@parameters('$connections')['sql']['connectionId']"
                        }
                    },
                    "method": "post",
                    "path": "/datasets/default/tables/@{encodeURIComponent(encodeURIComponent('[meta].[FileMetadata]'))}/items"
                },
                "runAfter": {
                    "Split_FileName": [
                        "Succeeded"
                    ]
                },
                "type": "ApiConnection"
            },
            "Split_FileName": {
                "inputs": "@split(triggerBody()?['Name'],'.')",
                "runAfter": {
                    "Create_GUID": [
                        "Succeeded"
                    ]
                },
                "type": "Compose"
            }
        },
        "contentVersion": "1.0.0.0",
        "outputs": {},
        "parameters": {
            "$connections": {
                "defaultValue": {},
                "type": "Object"
            }
        },
        "triggers": {
            "When_a_blob_is_added_or_modified_(properties_only)": {
                "inputs": {
                    "host": {
                        "connection": {
                            "name": "@parameters('$connections')['azureblob']['connectionId']"
                        }
                    },
                    "method": "get",
                    "path": "/datasets/default/triggers/batch/onupdatedfile",
                    "queries": {
                        "folderId": "JTJmcmVjZWl2ZWQ=",
                        "maxFileCount": 10
                    }
                },
                "metadata": {
                    "JTJmcmVjZWl2ZWQ=": "/received"
                },
                "recurrence": {
                    "frequency": "Minute",
                    "interval": 1
                },
                "splitOn": "@triggerBody()",
                "type": "ApiConnection"
            }
        }
    }
}

Answer 1

你已经清除了这个吗？

我也遇到了同样的麻烦。它已通过使用逻辑应用 JSON 中的“方法”参数修复。

我的函数仅接受“GET”方法，而逻辑应用 JSON 没有方法参数，因此我添加了“'method':'GET'”参数。