Azure流分析未馈送DocumentDB输出接收器 [英] Azure Stream Analytics is not feeding DocumentDB output sink

问题描述

我正在尝试将Azure Stream Analytics与DocumentDB集成在一起，并将其用作输出接收器.问题是，运行处理作业时，在DocDB中没有创建任何文档.我尝试测试查询，甚至尝试将输出镜像到存储帐户.在存储中正在创建包含所有值的json文件，但是DocDB保持为空.

I am trying to integrate Azure Stream Analytics with DocumentDB and use it as a output sink. Problem is, that there are no documents created in DocDB when the processing job is running. I tried to test my query and I have even tried to mirror the output to storage account. There is json file being created in the storage containing all the values, but DocDB stays empty.

这是我的查询:

WITH Res1 AS ( SELECT id,
    concat(
    cast( datepart(yyyy,timestamp) as nvarchar(max)),
    '-',
    cast( datepart(mm,timestamp) as nvarchar(max)),
    '-',
    cast( datepart(dd,timestamp) as nvarchar(max))) date, temp, humidity, distance, timestamp
FROM
    iothub Timestamp By timestamp)

Select *  into docdboutput FROM Res1
Select *  into test FROM Res1

我确实将documentDB输出正确设置为现有集合.我也尝试提供但不提供document id参数，并且两个选项均不起作用.创建DocDB数据库和集合时，我已将日期字段用作分区键.

I did set the documentDB output correctly to existing collection. I also tried to provide and not to provide document id parameter and neither of the options was working. I have used date field as a partition key when creating DocDB database and collection.

我也尝试过手动上传文件.我已经从存储帐户中创建的json文件中复制了行.我创建了包含此记录的单独的json文件，并通过门户将其手动上传到DocumentDB集合.成功了.这是输出到存储文件的一行示例:

I did try also manual document upload. I have copied line from the created json file in storage account. I created separate json file containing this one record and uploaded it manually to DocumentDB collection via portal. It succeeded. Here is example of one line that was output to storage file:

{"id":"8ace6228-a2e1-434d-a5f3-c2c2f15da309","date":"2017-2-10","temp":21.0,"humidity":20.0,"distance":0,"timestamp":"2017-02-10T20:47:54.3716407Z"}

如果我的查询有任何问题，请任何人给我建议，或者浏览我该如何进一步调查和诊断.

Please can anyone advice me, if there is some problem with my query, or navigate me how can I investigate and diagnose further.

推荐答案

您是否有机会使用具有< = 10K RU，并且在DocDb中定义了分区键的集合(也称为单一分区集合)?

Are you by any chance using a collection which has <=10K RUs, and has a partition key defined in DocDb (aka Single Partition Collection) ?

存在一个持续存在的缺陷，该缺陷阻止了对单个分区集合的输出.该问题应在下周结束之前解决.您目前的解决方法是尝试使用其他集合- a)具有> 10K RU(具有在DocDB中定义的分区键) b)具有< = 10K RU(具有在DocDB/ASA中定义的 no 分区键)

There is an ongoing defect that is blocking output to Single partitioned collections. This should be fixed by end of next week. Your workarounds at this point are try using a different collection -- a) with >10K RUs (with partition key defined in DocDB) b) with <=10K RUs (with no partition key defined in DocDB/ASA)

希望有帮助！

这篇关于Azure流分析未馈送DocumentDB输出接收器的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！