当前位置: 首页 > 知识库问答 >
问题:

从NiFi发布到Azure Cosmos Db

卢黎明
2023-03-14

我为我的文档创建了 Azure CosmosDb 数据库和容器。我使用NiFi作为主要的数据摄取工具,并希望用NiFi流文件中的文档来馈送我的容器。任何人都可以分享一种从NiFi将flowfile内容发布到Azure Cosmos Db的方法吗?

提前致谢

更新(2019.05.26):最后我用Python脚本,从NiFi调用来发布消息。我传递了一条消息作为参数。我选择python的原因是因为它在微软官方网站上有一些例子,有所有需要的连接设置和库,所以很容易连接到Cosmos。我尝试了Mongo组件,但无法连接到Azure(安全配置不工作),没有真正走得太远,因为Python脚本工作得很好。

共有2个答案

罗安宁
2023-03-14

Valeria。根据与Azure相关的Apache Nifi支持的组件列表,您只能获取Azure Blob存储、队列存储、事件中心等,不包括Cosmos DB。

因此,我建议您使用PutAzureBlobStorage为azure blob容器提供来自NiFi流文件的文档。然后,请在Azure数据工厂中创建复制活动管道,将数据从Azure Blob存储传输到Azure Cosmos DB。

刘弘济
2023-03-14

Azure CosmosDB公开了MongoDB API,因此您可以使用NiFi中提供的以下MongoDB处理器进行读取/查询/写入:

    < li >删除Mongo < li>GetMongo PutMongo < li>PutMongoRecord < li>RunMonogAggregation

有用的链接

  • https://docs.microsoft.com/en-us/azure/cosmos-db/mongodb-introduction
  • https://docs.microsoft.com/en-us/azure/cosmos-db/mongodb-feature-support
 类似资料:
  • 问题内容: 我正在使用Angular $ resource将模型发布到webapi端点,但是Angular将数据发送到请求有效负载中,而不是JSON正文或表单参数中。结果,模型总是以null结尾。 我的API如下: 请求标头为: 和请求有效载荷: 如果我在Fiddler中进行测试,并在正文中发布相同的JSON字符串,则可以按预期正确填充模型。 是否有在这种情况下可以使用的内置模型活页夹,或者可以在

  • 我使用Angular$资源将模型发布到webapiendpoint,但Angular在请求负载中发送数据,而不是JSON正文或表单参数。因此,该模型最终总是为空。 我的API如下: 请求头包括: 和请求有效载荷: 如果我在Fiddler中进行测试,在主体中发布相同的JSON字符串,那么正如预期的那样,模型是正确填充的。 在这种情况下,是否有一个内置的模型绑定器可以工作,或者在我可以使用的地方预先构

  • 嗨,有人能告诉我我在哪里出错了吗,我从powershell执行API调用时收到以下错误。我尝试过多种方式格式化正文,但无法使其正常工作。 我的代码;

  • 有人能告诉我如何让invokehttp处理器等待API响应消息并路由到下一步吗?感谢您的建议,如果有任何其他有效的/替代的方法,我们可以尝试处理这一用途。

  • 我正在尝试在CentOS系统上运行Apache NiFi。我下载了它并使用以下命令运行它: 结果如下: 然后,我用命令检查Apache NiFi的状态: 结果是: 但最后当我尝试访问http://localhost:8090/nifi或http://localhost:8080/nifi在我的浏览器上显示:无法连接。(我将http端口更改为8090以避免冲突,但仍然存在相同的问题)。请帮帮我,有什

  • 问题内容: 我的设置:Rails 3.0.9,Ruby 1.9.2,jQuery 1.6.2 我有一个表单,可以为用户显示多张照片和评论,我希望实现内嵌评论。 我想在用户点击textarea字段中的enter键后提交AJAX帖子。这是到目前为止我拥有的javascript(不完整) 我使用该方法是因为可以将内容替换为另一个AJAX调用。我需要的是jQuery 方法的语法,假设我需要传递诸如say