带有动态sql筛选查询的Azure Service Bus主题订阅

Question

可以通过为每个请求创建一个订阅并在之后删除它来解决此问题。但我不想创建这么多订阅。我的目标是每次调用函数时只更改过滤器。

示例代码：

var connectionString = ConfigurationManager.AppSettings["ServiceBus_CONNECTION_STRING"];
                var namespaceManager =
                    NamespaceManager.CreateFromConnectionString(connectionString);
                if (!await namespaceManager.TopicExistsAsync(topicName))
                {
                    // Configure Topic Settings.
                    var topic = new TopicDescription(topicName)
                    {
                        MaxSizeInMegabytes = 1024,
                        DefaultMessageTimeToLive = TimeSpan.FromMinutes(5)
                    };

                    await namespaceManager.CreateTopicAsync(topic);
                }

                if (!await namespaceManager.SubscriptionExistsAsync(topicName, subscription))
                {
                    await namespaceManager.CreateSubscriptionAsync(topicName, subscription);
                }

                var cts = new TaskCompletionSource<T>();
                var subClient =
                    SubscriptionClient.CreateFromConnectionString(connectionString, topicName,
                        subscription);

                var ruleDescription = new RuleDescription($"RequestIdRule{id}", new SqlFilter($"'id' ='{id}'"));

                await subClient.AddRuleAsync(ruleDescription);
                var options = new OnMessageOptions();

                subClient.OnMessage(m =>
                    {
                        try
                        {

                            var body = m.GetBody<T>();
                            cts.SetResult(body);
                        }
                        catch (Exception ex)
                        {

                            m.Abandon();
                        }
                    },
                    options);

                return await cts.Task;

            }
            catch (Exception ex)
            {
                throw;
            }

Answer 1

是否可以为订阅使用不同筛选器？

是的。单个主题及其所有订阅最多可以有2,000个SQL筛选器（100,000个用于相关筛选器）。请参阅此处的文档。

无法更新筛选器。您需要删除旧规则，并通过创建一个新规则来替换它。但是如果您在运行时经常这样做，我会质疑这种方法的效率。

或者，您可以让每个函数都有它的输入队列，链接这些函数就是向适当的Azure服务总线输入队列发送一条消息。

最后,

我的目标是每次调用函数时只更改过滤器。