从API更新Nifi敏感属性

敏感属性设置与其他属性设置一样简单。

使用nipyapi更新GetTwitter处理器中敏感属性的示例代码段。

# Custom method to return all processors in a process group by using group name; 
# Equivalent to nipyapi.canvas.list_all_processors(pg_id='root') but accepts group name
def get_all_processors_in_group(processgroup_name, "name"):
    # ...
    # ...

def update():
    processors_list = get_all_processors_in_group(processgroup_name, "name")
    processor = ... # Get 'GetTwitter' processor

    props = processor.component.config.properties
    props["Consumer Key"] = "Random key"
    props["Consumer Secret"] = "Random secret" # Sensitive value
    props["Access Token"] = "Random token"
    props["Access Token Secret"] = "Random token secret" # Sensitive value

    config = processor.component.config
    config.properties = props

    nipyapi.canvas.update_processor(processor, config)

可以使用UI、API或命令行工具(如NiFi CLI或NiPyAPI)设置敏感属性,与设置任何其他属性的方式相同。如果已使用TLS保护NiFi实例,则脚本和NiFi之间的所有调用都将被加密。您可以为脚本颁发自定义客户端证书以用于身份验证,或者使用Kerberos/SPNEGO(如果已配置)。