通过 REST 发布 NIFI 模板?

2024-05-06

我有多个 nifi 服务器,我希望能够通过脚本的 REST 接口将模板发布到这些服务器

The "/controller/templates" endpoint appears to be the proper REST endpoint to support POSTing an arbitrary template to my Nifi installation. enter image description here The "snippetId" field is what is confusing me, how do I determine "The id of the snippet whose contents will comprise the template"? Does anyone have an example of how I can upload a template "test.xml" to my server without having to use the UI?


API 在 1.0 中已移至:

POST /process-groups/{id}/templates/upload

例如,使用 Python 的 requests 库:

res = requests.post( "{hostname}/nifi-api/process-groups/{destination_process_group}/templates/upload".format( **args ), 
    files={"template": open( file_path, 'rb')} )
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

通过 REST 发布 NIFI 模板? 的相关文章

  • 配置来自 Nifi 的 HTTP POST 请求

    我正在尝试从 REST 客户端访问 WCF 服务 我正在从 REST 客户端向 WCF 服务发送 POST 请求 详细如下 供大家参考 The 服务合同定义如下 ServiceContract public interface IBZTso
  • 将 NiFi 中同一列中的字符串值替换为整数值

    我想更换一个 字符串值 并将该值输入为整数值使用 Nifi ReplaceText 我不知道如何在 NiFi 中实现这一点 所以我的场景如下 我将有一个 CSV 文件 其中包含几个带有整数的字段和几个作为字符串总值的字段 对于具有字符串值的
  • Nifi 中并行和顺序处理的等待通知

    我有一个要求 我需要并行执行 4 个作业 并且当在所有 4 个处理器中并行完成相同的项目作业时 然后触发下一个处理器 为此我使用了等待通知 流程就像 4个并行作业 gt notify 释放信号标识符 itemid 信号计数器名称 proce
  • 如何清除NiFi队列?

    我们正在 NiFi 中创建一些流 在某些情况下可能会建立队列 但由于某种原因 流无法按预期工作 在一天结束时 我想清除队列并以某种方式实现自动化 问题是我们如何从后端删除队列 我们有什么办法可以实现这一目标吗 除了 Bryan 提到的明确的
  • ExecuteSQL 和 ExecuteSQLRecord 之间的区别

    我想了解两个处理器之间的区别ExecuteSQL and ExecuteSQLRecord V1 8 及以上 后者是否提供了额外的东西 ExecuteSQL不是吗 我已经看到的一件事是执行 SQL 不维护 状态 做ExecuteSQLRec
  • OkHttp 是否在重定向时发送授权和其他潜在敏感标头?

    我通过 Apache NiFi 传递使用 OkHttp 我正在尝试确定如何在重定向上处理授权和其他敏感标头 NiFi 的 InvokeHTTP 处理器与 OkHttp 在重定向方面的唯一交互是here https github com ap
  • 使用 NiFi 更新 CSV 内字段中的值

    我想实现一个简单的用例 使用 NiFi 将 CSV 内字段中的多个字符串 文本值更新为整数值 例如 我的 CSV 文件如下所示 输入 CSV 文件 字段 1 字段 2 美国 苹果 美国 苹果 印度 葡萄 中国城 奥兰治 澳大利亚民族 桃子
  • Nifi:如何使 ListenHTTP 与 SSL 配合使用

    客观的 由于 Nifi 通过 HTTP 与其他工具集成 我必须ListenHTTP处理器面向公众 所有 3 个环境上的 API 网关对我来说太贵了 所以我关闭了所有虚拟机入口端口 除了ListenHTTP 对于外部网络 Issue 我的配置
  • Apache NiFi:使用映射值将列添加到 csv

    使用 GetFile 处理器将 csv 导入 NiFi 工作流程 我有一列由 id 组成 每个id代表一个特定的字符串 大约有3个id 例如 如果我的 csv 包含 name age id John 10 Y Jake 55 N Finn
  • 列的类型为没有时区的时间戳,但表达式的类型为字符变化:Nifi

    我正在尝试使用 nifi 将 CSV 记录插入 Postgres 数据库 示例 csv 文件 timenow location 2019 10 21 15 13 11 colombo nifi场景运行时 出现以下错误 错误列 timenow
  • 如何使用 NiFi 将字符串转换为 JSON 数组

    在 NiFi 中 我正在处理包含以下属性的流文件 Key my array Value u firstElement u secondElement 我想在此数组上拆分 flowFile 以单独处理每个元素 然后合并 我尝试使用SplitJ
  • Apache Nifi:使用更新记录处理器替换列中的值

    我有一个 csv 看起来像这样 name code age Himsara 9877 12 John 9437721 16 Razor 232 45 我必须更换色谱柱code根据一些正则表达式 我的逻辑如下面的 Scala 代码所示 if
  • 有没有办法更改 Nifi 中 PublishJMS 处理器的交付模式?

    我使用 Nifi PublishJMS 处理器向 IBM MQ 发送消息 消息在 MQ 中具有持久性 持久性 我想将其更改为非持久性 Nifi PublishJms 处理器中是否有属性可以纠正此问题 或者是从MQ端完成的 我无权访问 MQ
  • Apache NiFi 用于将数据从 RDMBS 导入到 HDFS - 与 SQOOP 的性能比较

    我们正在探索 Apache NiFi 作为满足我们企业需求的通用数据摄取工具 一种典型的数据摄取要求是从 RDBMS 移动数据 系统到 HDFS 我能够使用 NiFi 提供的GenerateTableFetch 和 ExecuteSQL 处
  • NiFi:ReplaceTextWithMapping 处理器

    我有以下插入语句 insert into temp1 values test1 test2 insert into temp2 values test3 预期成绩 insert into temp1 values 100 200 inser
  • Apache NIFI Jon 不会自动终止

    我是 Apache NIFI 工具的新手 我正在尝试从 mongo db 导入数据并将该数据放入 HDFS 中 我创建了 2 个处理器 第一个用于 MongoDB 第二个用于 HDFS 并且我正确配置了它们 该作业正在成功运行并将数据存储到
  • Apache NiFi 替换文本处理器以使用控制字符作为分隔符

    在将固定宽度文件转换为用普通字符 如 分隔时使用替换文本处理器 作为分隔符正在起作用 然而 考虑 u0001 或 A 或 A 并不能按预期工作 使用您可以使用的特殊字符literal unescapeXmlnifi表达函数 literal
  • 通过 REST 发布 NIFI 模板?

    我有多个 nifi 服务器 我希望能够通过脚本的 REST 接口将模板发布到这些服务器 The controller templates endpoint appears to be the proper REST endpoint to
  • Windows 上的 Nifi 命令

    在我当前的项目中 我一直在Windows操作系统上使用apache nifi 我已经提取了nifi 0 7 0 bin zip文件输入C 现在 当我跑步时 bin run nifi bat as 管理员我在命令行上看到以下消息 但无法运行
  • 尝试使用“UpdateAttribute”处理器解决删除时间戳格式转换错误,即 ConvertJSONtoSQL-> UpdateAttribute--> PutSQL

    来自这个答案 https stackoverflow com questions 45685703 nifi putsql timestamp datetime error cannot be converted error 4570101

随机推荐