Azure服务总线订阅中基于系统属性的SQLFilter

Question

我有一个使用本教程的工作示例，可以根据需要发送和接收主题/订阅：https://azure.microsoft.com/en-us/documentation/articles/service-bus-queues-topics-subscriptions/

但是，现在我想根据BrokeredMessage的to属性为每个订阅设置SQL过滤器。我后面的教程提到，有可能“创建订阅时，您可以提供一个对消息的属性进行操作的筛选表达式，包括系统属性（例如，Label）和自定义应用程序属性（例如StoreName.）”

如果我设置一个自定义属性，例如StoreName，如下所示：

message.Properties.Add("StoreName", "TestMe");

并使用SQL筛选器设置订阅,如下所示：

namespaceManager.CreateSubscription("MyNSTestTopic", "TestSubscription", new SqlFilter("StoreName = 'TestMe'"));

订阅按预期筛选。但是，如果我尝试使用BrokeredMessage对象作为属性（或标签），就像本文中描述的那样，我无法使其工作。我尝试了以下SQL筛选器，但没有成功。访问消息的系统属性的正确语法是什么？

html lang-html prettyprint-override">BrokeredMessage message = new BrokeredMessage();
message.To = "TestMe";

namespaceManager.CreateSubscription("MyNSTestTopic", "TestSubscription", new SqlFilter("To = 'TestMe'"));
namespaceManager.CreateSubscription("MyNSTestTopic", "TestSubscription", new SqlFilter("Message.To= 'TestMe'"));
namespaceManager.CreateSubscription("MyNSTestTopic", "TestSubscription", new SqlFilter("MessageTo= 'TestMe'"));
namespaceManager.CreateSubscription("MyNSTestTopic", "TestSubscription", new SqlFilter("messageto= 'TestMe'"));

Answer 1

本文主题订阅筛选器：

SQL筛选器-sqlfilter包含一个类似SQL的条件表达式，该条件表达式在代理中根据到达的消息的用户定义属性和系统属性求值。所有系统属性（都是BrokeredMessage类上显式列出的属性）必须在条件表达式中以sys.作为前缀。SQL子集实现了属性是否存在的测试(exist)、空值的测试(is null)、逻辑not/和/或、关系运算符、数值算术以及与like匹配的简单文本模式。

因此，在您的情况下，需要在sys.to属性上创建sqlfilter:

namespaceManager.CreateSubscription("MyNSTestTopic", "TestSubscription",
    new SqlFilter("sys.To = 'TestMe'"));