标签: azureservicebus

我创建了一个如下所示的 Azure 函数（实际上，Microsoft 模板完成了大部分工作！）：

[FunctionName("Function1")]
public static void Run([ServiceBusTrigger("%queue-name%", AccessRights.Listen)]string myQueueItem, TraceWriter log)
{
    log.Info($"C# ServiceBus queue trigger function processed message: {myQueueItem}");
}

我的 local.settings.json 看起来像这样：

{
    "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "..",
    "AzureWebJobsDashboard": "..",
    "AzureWebJobsServiceBus": "..",
    "queue-name":  "testqueue"

  }
}

然后我部署了这个功能。这是一个奇怪的问题，因为我的问题是它立即起作用，但我没想到它会起作用。function.json 在这里：

{
  "generatedBy": "Microsoft.NET.Sdk.Functions-1.0.0.0",
  "configurationSource": "attributes",
  "bindings": [
    {
      "type": "serviceBusTrigger",
      "queueName": "%queue-name%",
      "accessRights": "listen",
      "name": "myQueueItem"
    }
  ],
  "disabled": false,
  "scriptFile": "..\\bin\\FunctionApp8.dll",
  "entryPoint": "FunctionApp8.Function1.Run"
}

显然，local.settings.json 中的值已复制到功能设置中，但我在门户中看不到它们。我的问题是：这些设置现在存储在哪里（队列名称和 AzureWebJobsServiceBus）？

编辑：

该功能的我的应用程序设置：

我尝试使用 MassTransit 将消息发布到eventsAzure 服务总线中命名的主题。我在配置 MassTransit 以使用我预定义的主题时遇到问题events，而是为消息类型创建了一个由命名空间/类名命名的新主题。所以我想知道如何指定使用哪个主题而不是创建一个新主题。

这是我测试过的代码：

using System;
using System.Threading.Tasks;
using MassTransit;
using MassTransit.AzureServiceBusTransport;
using Microsoft.ServiceBus;

namespace PublisherNameSpace
{
    public class Publisher
    {
        public static async Task PublishMessage()
        {
            var topic = "events";
            var bus = Bus.Factory.CreateUsingAzureServiceBus(
                cfg =>
                {
                    var azureServiceBusHost = cfg.Host(new Uri("sb://<busname>.servicebus.windows.net"), host =>
                    {
                        host.OperationTimeout = TimeSpan.FromSeconds(5);
                        host.TokenProvider =
                            TokenProvider.CreateSharedAccessSignatureTokenProvider(
                                "RootManageSharedAccessKey",
                                "<key>"
                            );
                    });

                    cfg.ReceiveEndpoint(azureServiceBusHost, topic, e =>
                    {
                        e.Consumer<TestConsumer>();
                    });
                });

            await bus.Publish<TestConsumer>(new TestMessage { TestString = "testing" });
        } …

如果我将来使用这样的方式安排消息：

d = datetime.utcnow() + timedelta(minutes=5)
task = {"some": "object"}

sbs.send_queue_message(
    qn,
    Message(
        task, 
        broker_properties={'ScheduledEnqueueTimeUtc': d}
    )
)

那么有没有一种方法可以查看/删除已安排的消息？send_queue_message不返回任何东西，可以receive_queue_message理解的是，不会返回计划稍后排队的项目 - 所以我无法抓住它传递给delete_queue_message例如。

Azure 团队似乎知道这个用例，因为存储队列似乎有这样的功能：https : //azure.microsoft.com/en-gb/blog/azure-storage-queues-new-feature-pop-receipt-on -添加消息/

基本上我需要能够安排稍后排队的消息，但是可以取消。理想情况下，我还希望能够查看所有未来的计划任务，但能够仅存储可用于稍后删除排队消息的 id 就足够了。

Azure UI 也显示了活动/计划消息的数量，这似乎表明应该有某种方法可以查看这些计划消息！

队列存储会更好吗？或者服务总线是否有一些可行的方法？ScheduledEnqueueTimeUtc似乎比队列存储中的可见性超时更灵活，所以如果可以的话，坚持下去会很好。

我有一个 azure 函数，它发出一个基于 Promise 的 http post 请求并得到响应；现在我想将此响应发送到服务总线和不同的事件中心（azure 函数由不同的事件中心触发）。

函数表示在事件中心的情况下它已成功执行，但没有发送任何事件。在服务总线的情况下，我收到此错误NamespaceConnectionString should not contain EntityPath.

module.exports = async function (context, eventHubMessages) {
    context.log(`JavaScript eventhub trigger function called for message array ${eventHubMessages}`);

    var completeData = '';

    eventHubMessages.forEach((message, index) => {
        context.log(`Processed message ${message}`);
        completeData = message;
    });

    var output = '';

    const axios = require('axios');

    try {
        const response =  await axios.post('http://fake-endpoint', 
        {  data-json : completeData
        })
        context.log(`statusCode: ${response.statusCode}`);
        context.log(response.data);
        output += response.data;

        var time = new Date().toString(); 
        context.log('Event Hub message …