链接提供商

Question

我使用的是Apache Nifi，我正在编写一个tool以基于Nifi API自动化。这个工具是一个红宝石宝石，所以我想用它作为我的Nifi manifest中的傀儡类型/提供者。

类型（LIB /木偶/类型/ nifi_pg.rb）看起来像这样：

Puppet::Type.newtype(:nifi_pg) do 
    @doc = "Manage Nifi process groups" 

    ensurable 

    newparam(:name) do 

    isnamevar 

    desc "Process group Name" 

    validate do |value| 
    end 
    end 

    newparam(:id) do 
    desc "Process group ID" 

    validate do |value| 
    end 
    end 
end 

提供商（LIB /木偶/提供者/ nifi_pg/ruby​​.rb）看起来像这样：

require 'nifi_sdk_ruby' 

Puppet::Type.type(:nifi_pg).provide(:ruby) do 

    def create 
     nifi_client = Nifi.new() 
     nifi_client.set_debug(true) 
     nifi_client.create_process_group(:name => resource[:name]) 
    end 

    def destroy 
     nifi_client = Nifi.new() 
     nifi_client.set_debug(true) 
     nifi_client.delete_process_group(resource[:id]) 
    end 

    def exists? 
     false 
    end 
end 

使用它很简单：

nifi_pg {"test": 
    ensure => present 
} 

问题是我需要关于创建资源的一些信息（如新进程组标识）来使用它，例如，将模板上传到此新进程组。木偶资源不会返回任何东西。

任何想法解决？我想答案不是。

这个explanation完美地解释它。

Answer 1

可能有更简单的方法来完成此操作，但Puppet允许您登录到exec arbitrary commands，您可以将其与curl组合起来，以打NiFi REST API并检索任何必需的进程组ID。将PG ID提取到一个Ruby变量，并在下一个命令中简单地引用它。