java - 如何在java azure函数中使用@BlobOutput或@TableOutput

Question

官方文档似乎缺少有关使用这些输出绑定(bind)的文档，https://learn.microsoft.com/en-us/azure/azure-functions/functions-reference-java没有给出任何使用这些绑定(bind)的示例。

有人用过这些吗？我希望实现类似的目标:

@FunctionName("consumeNodeInfo")
fun consumeNodeInfoFromQueue(@QueueTrigger(queueName = "nodeinfos", connection = "AzureWebJobsStorage", name = "nodeinfos", dataType = "binary") addedNodeInfo: ByteArray,
                             @TableOutput(name = "networkmap", tableName = "networkmap") table: OutputBinding<SignedNodeInfoRow>) {
    table.value = SignedNodeInfoRow(addedNodeInfo)
}

open class SignedNodeInfoRow(val signedNodeInfo: ByteArray) {
    val rowKey = signedNodeInfo.deserialize<SignedNodeInfo>().raw.hash
}

Answer 1

@BlobOutput:

请引用我的示例代码:

@FunctionName("blob")
public String functionHandler(
            @QueueTrigger(name = "myQueueItem", queueName = "walkthrough", connection = "AzureWebJobsStorage") String queue,
            @BlobOutput(name = "blob", connection = "AzureWebJobsStorage" , path = "samples-java/2.txt") OutputBinding<String> blob) {

        blob.setValue(queue);
        return queue;
}

AzureWebJobsStorage 在 local.settings.json

中配置

{
  "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "<your connection string>",
    "AzureWebJobsDashboard": ""
  }
}

function.json:

{
  "scriptFile" : "..\\fabrikam-functions-1.0-SNAPSHOT.jar",
  "entryPoint" : "com.fabrikam.functions.Function.functionHandler",
  "bindings" : [ {
    "type" : "queueTrigger",
    "name" : "myQueueItem",
    "direction" : "in",
    "connection" : "AzureWebJobsStorage",
    "queueName" : "walkthrough"
  }, {
    "type" : "blob",
    "name" : "blob",
    "direction" : "out",
    "connection" : "AzureWebJobsStorage",
    "path" : "samples-java/2.txt"
  } ],
  "disabled" : false
}

<小时/>

@TableOutput:

仅供总结:

我们可以从此 doc 检查 function.json 中的属性。 永远不要忘记名为 RowKey 的属性。

示例代码:

@FunctionName("consumeNodeInfo")
fun consumeNodeInfoFromQueue(@QueueTrigger(queueName = "nodeinfos", connection = "AzureWebJobsStorage", name = "nodeinfos", dataType = "binary") addedNodeInfo: ByteArray,
                             @TableOutput(name = "networkmap", tableName = "networkmap", connection = "AzureWebJobsStorage", partitionKey = "nodeInfos") table: OutputBinding<SignedNodeInfoRow>) {
    val nodeInfo = addedNodeInfo.deserialize<SignedNodeInfo>()
    table.value = SignedNodeInfoRow(nodeInfo.raw.hash.toString(), addedNodeInfo.toBase58())
}

data class SignedNodeInfoRow(val RowKey: String, val arrayAsBase58String: String)

希望对您有帮助。