azure - 如何使用 azure 流分析进行多输入和多输出
问题描述
我正在尝试处理来自事件中心的传入数据,我需要以多种方式处理数据,因此我正在创建多个输入,并且我需要将不同的输入映射到不同的输出,例如,1,我需要将所有数据插入到 blob 中。2,我需要选择很少的列并在power bi中实时可视化这些数据。如何实现这一目标。
解决方案
对我来说,棘手的部分是将多个输入输入到一个输出中。我能够使用 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
推荐阅读
- javascript - 如何在 mongo 聚合查询中使用 javascript 对象
- android - 套接字连接适用于 PC,但不适用于 Android 平板电脑。Xamarin 表单应用程序
- ios - 如何自定义 UICollectionView 在水平方向左对齐
- javascript - 如何修复此错误以及如何正确编写我的 github 用户名?是有美元符号还是没有?
- azure - 来自 Azure Front Foor 剥离路径的 Azure Appservice 简单身份验证代理
- c# - 有没有比客户端控制台应用程序中的 ClientWebSocket 更好的方式从 websocket 服务器接收数据?
- web - 如何通过 Odoo 网站中的表单获取用户给出的数字
- angular - 错误:node_modules/@angular/material/core/common-behaviors/constructor.d.ts:14:64 - 错误 TS1005: ';' 预期的
- php - 从第三方网站 POST 后丢失会话数据
- android - 共享偏好总是在改造拦截器中获得旧值