Azure подключение триггера большого двоичного объекта за пределами значений - PullRequest
0 голосов
/ 14 июля 2020

Я впервые создаю триггерную функцию Azure blob, и мне очень странно, что строка подключения может храниться только в разделе Values ​​моего local.settings. json

public async Task Run([BlobTrigger("container/filename.json", Connection = "TriggerConnectionString")]
        Stream myBlob, ILogger log)

{
  "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "UseDevelopmentStorage=true",
    "TriggerConnectionString": "myConnectionString"
  },

В другой части моего кода я подключаюсь к той же учетной записи хранения, чтобы прочитать файл и выполнить какое-то действие, и для этого я использую IOptions для чтения раздела моей конфигурации, который вы можете увидеть ниже, но из-за этот триггер, который я хочу добавить, мне нужно, чтобы строка подключения была в двух местах в моих настройках. .settings. json кроме раздела Values ​​(т.е. ConnectionString в MyStorageSettings)?

1 Ответ

0 голосов
/ 14 июля 2020

Значение в local.settings. json будет передано переменной окружения. Так что, если есть необходимость получить что-то из переменной окружения, вы должны установить это в Values. Это сделано намеренно, функция azure на локальном компьютере не считывает настройки из local.settings. json напрямую, она считывает настройки из переменной среды.

Исходя из вашей ситуации, у вас есть два способа добиться что хотите:

1, пусть ваши настройки такие:

  "Values": {
    "MyStorageSettings_ConnectionString": "myConnectionString",
    "MyStorageSettings_ContainerName": "myStorageContainerName",
    "MyStorageSettings_FileName": "filename.json"
  }

2, создайте свой код для разбора json файла.

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;
using Newtonsoft.Json.Linq;
using System.Text;

namespace HttpTrigger
{
    public static class Function1
    {
        public static string GetFileJson(string filepath)
        {
            string json = string.Empty;
            using (FileStream fs = new FileStream(filepath, FileMode.Open, System.IO.FileAccess.Read, FileShare.ReadWrite))
            {
                using (StreamReader sr = new StreamReader(fs, Encoding.GetEncoding("utf-8")))
                {
                    json = sr.ReadToEnd().ToString();
                }
            }
            return json;
        }
        //Read Json Value
        public static string ReadJson()
        {
            string jsonfile = "custom.json";
            string jsonText = GetFileJson(jsonfile);
            JObject jsonObj = JObject.Parse(jsonText);
            string value = ((JObject)jsonObj["MyStorageSettings"])["ConnectionString"].ToString();
            return value;
        }
        [FunctionName("Function1")]
        public static async Task<IActionResult> Run(
            [HttpTrigger(AuthorizationLevel.Function, "get", "post", Route = null)] HttpRequest req,
            ILogger log)
        {
            string value = ReadJson();

            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" + value);
        }
    }
}
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...