Azure Stream Analytics如何处理5个以上的查询？

Question

我创建了一个ASA作业，还创建了一个输入（eventhub）和6个输出（2个cosmos和4个服务总线队列）查询如下。 SA允许编写5个以上的查询，但在活动日志中却有错误。因此，我也遇到了水印延迟问题。

1: Select
             *
          INTO
             CosmosOutput
          FROM
             eventhubinput ;
2:       Select
             id,long,lat,timestamp
          INTO
             CosmosOutput1
          FROM
             eventhubinput ;
3:       Select
             *
          INTO
             SB1
          FROM
             eventhubinput 
           Where <condition>;

4:          Select
             *
          INTO
             SB2
          FROM
             eventhubinput 
           Where <condition>;
5:          Select
             *
          INTO
             SB3
          FROM
             eventhubinput 
           Where <condition1>;
6:          Select
             *
          INTO
             SB4
          FROM
             eventhubinput 
           Where <condition1>;

问题：

如何有效地编写5个以上的查询？预先感谢！

Answer 1

由于有多个查询，您可以尝试分配Stream Units Settings。

Streaming Units（SU）代表分配给执行Stream Analytics作业的计算资源。 SU的数量越多，为您的作业分配的CPU和内存资源就越多。为特定作业选择所需的SU数量取决于输入的分区配置以及作业中定义的查询。

当然，SU会产生更多的成本。另一种解决方法，您可以将azure function output设置为替换一些查询。例如，我注意到您需要在完全相同的条件下将数据推送到不同的Service Bus输出中。您可以将它们汇总为一个查询并将相同的数据作为参数推送到azure函数中。在azure函数中，配置多个output bindings of service bus。希望我对此表示清楚。