如何在Azure中使用nodejs在eventhub中创建使用者组? 试图复制.net SDK提供的内容,但无效。 任何指针都会有所帮助。 答案 0 :(得分:1) 这是有效的过程: https://docs.microsoft.com/en-us/rest/api/eventhub/create-consumer-group 步骤: SAS令牌: https://docs.microsoft.com/en-us/rest/api/eventhub/generate-sas-token uri-您的eventhub的网址
saName-您的托管策略的名称
saKey-EventHub管理策略的主键/辅助键(确保它具有Manage) 请求参数: URL: 标题: 有效载荷: 可能的退货状态: 如果您发现任何其他问题,请发表评论。 答案 1 :(得分:0) 事件中心Node.JS SDK不支持管理操作。 尝试使用https://www.nuget.org/packages/Microsoft.Azure.Management.EventHub/之类的管理客户端const { NamespaceManager } = require("@azure/service-bus");
let namespaceManager = NamespaceManager.CreateFromConnectionString(eventHubConnectionString);
let ehd = namespaceManager.GetEventHub(eventHubPath);
namespaceManager.CreateConsumerGroupIfNotExists(ehd.Path, consumerGroupName);
2 个答案:
function createSharedAccessToken(uri, saName, saKey) {
if (!uri || !saName || !saKey) {
throw "Missing required parameter";
}
var encoded = encodeURIComponent(uri);
var now = new Date();
var week = 60*60*24*7;
var ttl = Math.round(now.getTime() / 1000) + week;
var signature = encoded + '\n' + ttl;
var signatureUTF8 = utf8.encode(signature);
var hash = crypto.createHmac('sha256', saKey).update(signatureUTF8).digest('base64');
return 'SharedAccessSignature sr=' + encoded + '&sig=' +
encodeURIComponent(hash) + '&se=' + ttl + '&skn=' + saName;
}
Content-Type: application/atom+xml;type=entry;charset=utf-8
Host: your-namespace.servicebus.windows.net
Authorization: {replace with the content from your SAS Token}
<entry xmlns="http://www.w3.org/2005/Atom">
<content type="application/xml">
<ConsumerGroupDescription xmlns="http://schemas.microsoft.com/netservices/2010/10/servicebus/connect" xmlns:i="http://www.w3.org/2001/XMLSchema-instance">Any name you want</ConsumerGroupDescription>
</content>
</entry>
201 -- Successful Creation
404 -- Not found, you are using a name that does not exist
409 -- The messaging entity 'XXX' already exists.