如何解决Azure流分析OutputDataConversionError.InvalidColumnValue问题
我是Azure流分析的新手。在我的项目中,我有一个事件中心作为输入数据流,它发送不同类型的流。以示例为例,我接收到Test1和Test2 json类型作为输入。当我收到Test1 json类型时,我需要将数据保存到其他类型的Cosmos container1和container2中。为此,我编写了如下查询
WITH
MyTest1 AS
(
SELECT
test1.id as id,test1.userid as userid,test1.ouid as ouid,test1.bid as bid,test1.entid as entid,test1.action as action,test1.time as time,test1.data as data
FROM
inputeventhub
),MyTest2 AS
(
SELECT
test2.id as id,test2.userid as userid,test2.ouid as ouid,test2.bid as bid,test2.entid as entid,test2.action as action,test2.time as time,test2.data as data
FROM
inputeventhub
)
SELECT * INTO auditlogscontainer FROM MyTest1
SELECT * INTO sample1containeroutput FROM MyTest2
id是Cosmos文档ID。
使用上述查询,我能够将流数据保存到各自的容器中,但最终我也收到错误“ OutputDataConversionError.InvalidColumnValue
”。似乎上述查询已执行两次,因为已经存在具有相同ID的文档。
请帮助我
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。