如何将上传到容器中单独文件夹的blob读取到流分析作业中

Question

我在中央应用程序中有几个物联网设备，它们正在向Azure blob容器发送遥测。对于每个blob，都会在容器中创建一个单独的文件夹(基于上传时间)。下面的快照显示了目录，在类似的war中，创建了多个目录/子目录来存储blob。

​

如何将此数据读取到我的流分析作业中。我有一个流分析作业，使用blob容器作为输入，即使容器不断地接收数据，但当我运行select *查询时，它没有显示任何数据。请让我知道我应该如何将blob输入到流分析中，其中每个blob都存储在容器中的单独文件夹中。

Answer 1

通常情况下，如果我们有大量的数据，通过查询来拉取它们将需要时间。

尝试获取如下数据：

SELECT
    BlobName,
    EventProcessedUtcTime,
    BlobLastModifiedUtcTime
FROM Input

您还可以在路径前缀模式上指定{date}，{time}等标记，以帮助引导Stream Analytics对要读取的文件进行读取。

当作业运行足够长的时间时，似乎会有一些输出。在这些输出记录中，我们可以注意到我的自定义时间戳字段和常规时间戳字段之间有很大的延迟

有关如何配置流输入的详细信息，请参阅blog

此外，如果要从容器的根读取blob，请不要设置路径模式。在路径中，您可以指定以下三个变量的一个或多个实例：{date}、{time}或{分区}