首页 > 解决方案 > 如何使用 azure 流分析进行多输入和多输出

问题描述

我正在尝试处理来自事件中心的传入数据,我需要以多种方式处理数据,因此我正在创建多个输入,并且我需要将不同的输入映射到不同的输出,例如,1,我需要将所有数据插入到 blob 中。2,我需要选择很少的列并在power bi中实时可视化这些数据。如何实现这一目标。

标签: azurepowerbiazure-storageazure-eventhubazure-stream-analytics

解决方案


对我来说,棘手的部分是将多个输入输入到一个输出中。我能够使用 WITH 语句和 UNION 使其工作:

WITH combinedInput AS
(
    SELECT [col1], null AS [col2], 'FromSource1' AS [sourceTable]
    FROM [Source1]
    UNION
    SELECT [col1], [col2], 'FromSource2' AS [sourceTable]
    FROM [Source2]  
)
SELECT * 
INTO [outputLocation]
FROM combinedInput

要将其输出到多个输出,您应该能够将附加的 SELECT * INTO 表达式添加到末尾,如下所示:

WITH combinedInput AS
(
    SELECT [col1], null AS [col2], 'FromSource1' AS [sourceTable]
    FROM [Source1]
    UNION
    SELECT [col1], [col2], 'FromSource2' AS [sourceTable]
    FROM [Source2]  
)
SELECT * 
INTO [outputLocation1]
FROM combinedInput
SELECT * 
INTO [outputLocation2]
FROM combinedInput

推荐阅读