Azure流分析如何处理多个输出表?

2023-12-02

我创建了一项 ASA 作业,还创建了 1 个输入别名和 1 个输出别名
像这样

我像这样编辑了查询部分

WITH 
[StreamData]
AS (
SELECT
    employee_id, 
    first_name,
    last_name,
    age,
    salary
FROM 
  [DeviceDataStream] 
WHERE
    [ObjectType] IS NULL -- Filter out device info and command responses
) 

SELECT
    employee_id, 
    first_name,
    last_name,
    age,
    salary
INTO
    [Telemetry]
FROM
    [StreamData]

我已经在 SQL 数据库中创建了表
像这样

我从物联网设备的输入是这样的

{"employee_id":4,"first_name":"Joseph","last_name":"Marshal","age":34,"salary":890000}

到目前为止,一切都工作正常。

现在我想将我的输入 JSON 存储到基于不同的表type我的新输入 JSON 将是这样的

{"type":"emp","employee_id":4,"first_name":"Joseph","last_name":"Marshal","age":34,"salary":890000}

不同的字段将有不同的类型,并且根据我想将数据存储在不同的表中,所以我需要进行哪些更改以及在哪里进行更改,请指导我。谢谢


嘿终于我得到了简单的解决方案,我为每个输出表创建了一个输出

像这样

我的查询是这样的

WITH 
    [StreamData]
AS (
   SELECT
    *
    FROM 
      [DeviceDataStream] 
    WHERE
       [ObjectType] IS NULL -- Filter out device info and command responses
) 

SELECT
   EventProcessedUtcTime,
    PartitionId,
    EventEnqueuedUtcTime,
    IoTHub,
    employee_id, 
    first_name,
    last_name,
    age,
    salary
INTO
    [Telemetry]
FROM
    [StreamData]
WHERE type = 'emp'   --Table 1

SELECT
    EventProcessedUtcTime,
    PartitionId,
    EventEnqueuedUtcTime,
    PersonID, 
    FirstName,
    LastName,
    City,
    height
INTO
    [TelemetryP]
FROM
    [StreamData]
WHERE type = 'prsn'  --Table 2
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

Azure流分析如何处理多个输出表? 的相关文章

随机推荐

  • 聊天客户端表情窗口JAVA

    我一直在致力于创建一个聊天客户端 java swing 并且我刚刚使我的表情符号完全可用 但除了让用户输入 之外 例如 我想提供一个包含所有可用表情符号的弹出窗口 我正在寻找的是一种制作这样一个窗口的方法 例如像 Skype 的那样 我可以
  • 在多个节点实例中共享 IO 对象

    我想在两个节点实例之间共享由 socket io 创建的房间 已经使用 redis store 但无法在不同的节点实例上获取 io sockets in ROOM ID emit MESSAGE DATA 我在尝试 实例A io set s
  • C中的宏如何分配内存?

    我想知道C中的内存是如何分配给 define变量的 define VAR1 10 我有 2 个问题 VAR1 的类型是什么 VAR1 存储在哪个内存段中 VAR1 存储在哪个内存段中 在任何一个细分市场中 VAR1仅在预处理阶段相关 在运行
  • HTML 创建等大小的方形网格图片系统

    如何创建具有相同大小的正方形垂直和水平对齐的图片网格系统 下面是一个 2 x 2 的图片系统 由于某种原因 图像未对齐 如果需要的话 我希望能够稍后自定义正方形 使它们成为具有特定尺寸的矩形 也喜欢使用引导程序
  • Android DOM 解析器 - 从描述标签检索图像链接

    我正在使用 DOM 解析器来解析此 XML feed http loc grupolusofona pt index php format feed 我的解析器对所有标签都工作得很好 我只是缺少能够从描述标签中检索图像的想法 feed 上的
  • 图像的路径和扩展

    我想从iPhone设备获取相册图像的路径a 我还需要该图像的扩展名和他们的名字 newFilePath NSHomeDirectory stringByAppendingPathComponent textFieldNormalFile n
  • 自定义 ItemTemplate 未显示在 Visual Studio 2010 中 - 添加新项

    我之前在 VS2005 2010 中创建过 ItemTemplates 从来没有遇到过任何问题 在 Windows8 上使用 VS 2012 Ultimate 版本时 我正在创建的 ItemTemplate 未显示在 添加新项 列表中 仅尝
  • 定义函数模板特化的正确语法是什么?

    在 C Primer Plus 2001 捷克语翻译 中 我发现了这些不同的模板专业化语法 函数模板 template
  • (BYTE)-1 是什么意思

    我正在阅读别人的代码 define CPUTYPE INVALID BYTE 1 这意味着什么 我想它具有与以下相同的效果 define CPUTYPE INVALID 255 如果我们已经有 typedef unsigned char B
  • 在 ASP.NET 中,内联表达式是在后面的代码之前还是之后执行?

    Do ASP 内联表达式 在执行代码隐藏中的代码之前或之后在服务器上运行 内联代码在 asp net 页面生命周期中预渲染页面之后执行 因此 它可以在某些事情之前运行 也可以在某些事情之后运行 在此处阅读页面生命周期 http msdn m
  • 推送到 GitHub 时出错 - 权限不足,无法将对象添加到存储库数据库

    我在尝试对 GitHub 存储库执行 git Push 时遇到异常错误 Counting objects 8 done Delta compression using 2 threads Compressing objects 100 4
  • D3 刷分组条形图

    我试图让刷牙工作与此示例类似 但使用分组条形图 http bl ocks org mbostock 1667367 我对刷牙的工作原理不太了解 我找不到任何好的教程 所以我对出了什么问题有点不知所措 我将尝试在下面包含相关的代码 该图表按天
  • Typescript 无法将对象字面量分配给泛型类型

    如果我尝试将对象文字与具有类型约束的泛型类型一起使用 我会收到类型错误 我正在努力找出原因 type WithKey readonly akey string function listOfThings
  • 通过索引访问 collections.OrderedDict 中的项目

    假设我有以下代码 import collections d collections OrderedDict d foo python d bar spam 有没有办法以编号的方式访问这些项目 例如 d 0 foo s Output d 1
  • 如何在没有 Firebase 的情况下为 React Native 应用程序设置 Google 登录?

    我需要将谷歌登录方法添加到我的反应本机应用程序中 我使用了 react native google signin 包 我也在谷歌控制台中制作了一个项目 但当我尝试登录时出现错误 它给出错误 发生了其他错误 并且它位于我的 signIn 函数
  • 停止播放通过 SoundEffect.FromStream 调用的声音

    我有一些 Windows Phone 7 代码 可以使用 SoundEffect FromStream 开始播放声音 我使用它而不是普通的媒体对象 因为我需要多个音频剪辑位于一页上 但是 根据某些外部事件 我想停止播放特定的声音 由于通过
  • 比较 datetime2 时 SQL 忽略纳秒

    我有 2 张桌子 上面有一个datetime2各场 其中一个表也存储了纳秒 而另一个表最多只存储毫秒 无法更改此数据 现在我想比较这两个表并检查是否datetime2值匹配 但我必须为此忽略纳秒 样本数据 Table1 Table2 201
  • 在 IE 11 中获取未定义的 JavaScript 函数

    在 IE 11 中调用函数时出现一些错误 在我的例子中 一个脚本中有两个脚本
  • 用于比较具有变音符号和非变音变体的字符串的正则表达式

    任何人都可以帮助我使用 JavaScript 正则表达式 我可以使用它来比较相同的字符串 同时考虑到它们的非变音版本 例如 在德语中这个词Gr e也可以写成Gruesse 这两个字符串被认为是相同的 映射 暂时忽略大小写 是 ae ue o
  • Azure流分析如何处理多个输出表?

    我创建了一项 ASA 作业 还创建了 1 个输入别名和 1 个输出别名 像这样 我像这样编辑了查询部分 WITH StreamData AS SELECT employee id first name last name age salar