我试图基于Azure功能更新Azure表中的行。我看到Table绑定可以处理一个ICollector,它有一个Add方法,它会添加一行。我还看到你使用IQueryable来读取数据。
您如何更新数据中的特定行?
我在WebJobs中看到了与InsertOrReplace相关的东西,它是TableOperations的一种方法,但我不知道它是否或如何发挥作用以及如何在Azure Functions中使用它。
以下是您可以执行此操作的一种方法。我们的下一个版本将使这些步骤变得更加容易,但是现在您需要手动引入Azure Storage SDK。
首先,按照this help page的“包管理”部分中的步骤操作,以获取Azure Storage SDK。您将上传一个类似于此的project.json
到您的函数文件夹:
{
"frameworks": {
"net46":{
"dependencies": {
"WindowsAzure.Storage": "7.0.0"
}
}
}
}
注意:在下一个版本中,我们将自动包含Azure Storage SDK,以便您可以直接在代码中使用它。在提取包后,您可以在“集成”选项卡选项卡“高级编辑器”中输入如下所示的功能元数据:
{
"bindings": [
{
"name": "input",
"type": "manualTrigger",
"direction": "in"
},
{
"name": "table",
"type": "table",
"tableName": "test",
"connection": "<your connection>",
"direction": "in"
}
]
}
以下是相应的代码。我们绑定到CloudTable
这里让我们读/写实体:
#r "Microsoft.WindowsAzure.Storage"
using System;
using Microsoft.WindowsAzure.Storage;
using Microsoft.WindowsAzure.Storage.Table;
public static void Run(string input, CloudTable table, TraceWriter log)
{
TableOperation operation = TableOperation.Retrieve<Person>("AAA", "001");
TableResult result = table.Execute(operation);
Person person = (Person)result.Result;
log.Verbose($"{person.Name} is {person.Status}");
person.Status = input;
operation = TableOperation.Replace(person);
table.Execute(operation);
}
public class Person : TableEntity
{
public string Name { get;set; }
public string Status { get;set; }
}
我在本例中使用了ManualTrigger,但表绑定将适用于您拥有的任何触发器。通过上面的设置,我可以在门户网站的运行输入框中输入一个值并点击运行。该函数将查询实体,输出其当前值,然后使用我的输入进行更新。
其他排列也是可能的。例如,如果您有来自另一个绑定参数的实体实例,则可以使用CloudTable以类似的方式更新它。
使用当前版本的函数,我能够使用声明性绑定进行行更新。以下是HTTP触发器的示例,它会增加Azure Table行中的数字。
function.json
:
{
"bindings": [
{
"authLevel": "function",
"name": "req",
"type": "httpTrigger",
"direction": "in",
"route": "HttpTriggerTableUpdate/{partition}/{rowkey}"
},
{
"name": "$return",
"type": "http",
"direction": "out"
},
{
"type": "table",
"name": "inputEntity",
"tableName": "SOTrial",
"partitionKey": "{partition}",
"rowKey": "{rowkey}",
"connection": "my_STORAGE",
"direction": "in"
},
{
"type": "table",
"name": "outputEntity",
"tableName": "SOTrial",
"partitionKey": "{partition}",
"rowKey": "{rowkey}",
"connection": "my_STORAGE",
"direction": "out"
}
],
"disabled": false
}
C#功能:
#r "Microsoft.WindowsAzure.Storage"
using System;
using System.Net;
using Microsoft.WindowsAzure.Storage.Table;
public class Entity : TableEntity
{
public int Number {get; set;}
}
public static HttpResponseMessage Run(HttpRequestMessage req, string partition,
string rowkey, Entity inputEntity, out Entity outputEntity)
{
if (inputEntity == null)
outputEntity = new Entity { PartitionKey = partition, RowKey = rowkey, Number = 1};
else
{
outputEntity = inputEntity;
outputEntity.Number += 1;
}
return req.CreateResponse(HttpStatusCode.OK, $"Done, Number = {outputEntity.Number}");
}
使用today's bindings,您可以将ETag
属性设置为值*
来进行upsert:
[FunctionName("Function1")]
public static async Task<IActionResult> Run(
[HttpTrigger(AuthorizationLevel.Function, "get", "post", Route = null)] HttpRequest req,
ILogger log,
[Table("test")] IAsyncCollector<PocoClass> table)
{
log.LogInformation("C# HTTP trigger function processed a request.");
string name = req.Query["name"];
if (name == null)
return new BadRequestResult();
await table.AddAsync(new PocoClass { Name = name });
return new OkObjectResult($"Hello, {name}");
}
public sealed class PocoClass
{
public string PartitionKey { get; } = "partition";
public string RowKey { get; } = "row";
public string ETag { get; } = "*";
public string Name { get; set; }
}