问题描述
我想使用 Powershell 创建一个 Azure 函数,该函数将从 Azure 事件中心读取数据.Azure 函数有一个模板可以从 Azure 事件中心获取数据,但我不知道如何将相同的数据发布到本地托管的 REST API.
我已经为本地连接创建了一个混合连接.
我是 Powershell 开发的新手,因此寻求您的帮助.此外,如果有人可以建议任何博客以获取有关使用 Powershell 的 azure 函数开发标准实践的更多详细信息,那将是一个很大的帮助.
I want to create a Azure function using Powershell which will read data from the Azure Event Hub. Azure function has a template to get the data from the Azure Event hub and but I don't know how to post the same data to a REST API hosted on on-prem.
I have already created a hybrid connection for the on-prem connectivity.
I am new to Powershell development hence seeking your help.Also, it would be a great help if someone can suggest any blog(s) to get more details on azure function development standard practice using Powershell.
以下是我要更新的代码片段.
Following is the code snippet that I want to update.
run.ps1
param($eventHubMessages, $TriggerMetadata)
Write-Host "PowerShell eventhub trigger function called for message array: $eventHubMessages"
$eventHubMessages | ForEach-Object { Write-Host "Processed message: $_" }
host.json
{
"version": "2.0",
"managedDependency": {
"Enabled": true
},
"extensionBundle": {
"id": "Microsoft.Azure.Functions.ExtensionBundle",
"version": "[2.*, 3.0.0)"
}
}
function.json
{
"bindings": [
{
"type": "eventHubTrigger",
"name": "eventHubMessages",
"direction": "in",
"eventHubName": "pwo-events",
"connection": "eventhub-reciever-policy",
"cardinality": "many",
"consumerGroup": "$Default"
}
]
}
推荐答案
要从powershell脚本中的代码访问对象,必须在脚本的param部分添加function.json文件中绑定的名称.
To access to the object from the code in powershell script, the name of the bindings in the function.json file must be added in param section of the script.
# Input bindings passed via param
param([byte[]] $Trigger, [String[]] $InputBlob, $TriggerMetadata)
# Output passed via Push-OutputBinding
Push-OutputBinding -name OutputBlob -value $SomeValue
流程结构:
此外,我们有一个博客,其中包含有关 eventthub 遥测的信息 Powershell.
Also, we have a blog which covers the info about eventhub telemetry with Powershell.
这篇关于Azure 函数使用 Powershell 使用来自事件中心的数据并将其发布到 REST API的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!