Azure eventhub到NoSQL数据库

Question

我当前正在使用azure eventhub发送/接收数据。我想将我的物联网设备从Azure连接到NoSQL数据库，这样从物联网数据生成的JSON消息就可以存储在NoSQL数据库（可能是cosmosDB）中。你知道吗

我试图使用function app（classic）来处理数据流，但似乎不起作用。你知道吗

所以，管道可能需要这样：

物联网->；活动中心->；CosmosDB（MongoDB？）->；Azure数据包

我需要建立前三个步骤，我更喜欢使用python语言。你们能推荐一些工具吗？你知道吗

一个简短的示例代码将非常感谢。你知道吗

Answer 1

如果您希望继续使用Python，那么不确定eventhub是否是正确的选择。两种可能的解决方案是物联网设备->；物联网集线器->；服务总线->；应用程序功能->；Cosmos DB->；Azure Databricks。The function here could be written in Python，这可能不是最有效的解决方案，尽管它会改变发送给service bus的消息数量，然后会改变Function的定价层。你知道吗

另一个可能更理想的设置是物联网设备->；物联网中心->；流分析->；CosmosDb->；Azure Databricks。此模式不使用Python，但可以使用JavaScript或Steam Analytics Querying轻松地转换数据。你知道吗

现在，CosmosDb->；Databricks可能是它自己的难题，这取决于如何建立连接，即到CosmosDb的连接字符串。这些信息很可能应该存储在一个Azure Key Vault中，Databricks和Key Vault之间的集成仍在公开预览中。你知道吗

Answer 2

cosmosdb团队已经为这个场景创建了一个参考应用程序，应该对您有用。该解决方案有一个物联网中心，由写入Cosmos DB的Azure函数读取。您可以在这里查看架构图并获取此应用程序的源代码https://github.com/AzureCosmosDB/scenario-based-labs/blob/master/IoT/Demo%20step-by%20step%20-%20Cosmos%20DB%20scenario-based%20labs%20-%20IoT.md#solution-architecture。你知道吗

这个应用程序是用C语言编写的，使用Cosmos Core（SQL）API。如果需要（https://github.com/Azure/azure-cosmos-python/），可以使用pythonsdk，但不确定为什么要使用mongodbapi。如果这是一个新的应用程序，那么更容易使用核心API。你知道吗

希望这有帮助。你知道吗