c# - 值之外的 Azure Blob 触发连接
问题描述
我第一次创建 Azure blob 触发函数,我发现连接字符串只能存储在 local.settings.json 的 Values 部分中,这真的很奇怪
public async Task Run([BlobTrigger("container/filename.json", Connection = "TriggerConnectionString")]
Stream myBlob, ILogger log)
{
"IsEncrypted": false,
"Values": {
"AzureWebJobsStorage": "UseDevelopmentStorage=true",
"TriggerConnectionString": "myConnectionString"
},
在我的代码的另一部分中,我连接到同一个存储帐户以读取文件并执行一些操作,为此我使用 IOptions 来读取我的配置的一部分,您可以在下面看到,但由于这个触发器我要添加,我需要在我的设置中的两个地方有连接字符串。
"MyStorageSettings": {
"ConnectionString": "myConnectionString",
"ContainerName": "myStorageContainerName",
"FileName": "filename.json"
}
有没有办法让 blob 触发器中的连接字符串从 local.settings.json 中的“值”部分(即 MyStorageSettings 下的 ConnectionString)中读取?
解决方案
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);
}
}
}
推荐阅读
- python - 从时间模块获取输出作为列表
- html - 遍历数组时面临实现轮播的困难
- c++ - 是否可以使用 std::array 作为 hash_table 值,但大小不同
- javascript - Angular 9 FormModule 单元测试
- amazon-web-services - Gitlab CI 定价共享运行器与自托管 aws 运行器
- bash - 执行 tail -f 直到找到 BACKWARDS 模式
- javascript - 主题php联系表
- python - AttributeError: __enter__ 尝试从 MySQL 查询时出错
- ssl - 端口 443 中的 tomcat ssl 配置
- javascript - 结合 CSS 和 SVG 过滤器来编辑和保存图像