NiFi 更新 xml 时不更新模板信息



我试图将我的NIFI作业从开发到质量检查以及I正在使用模板中。我知道模板没有存储SENSTIVE信息(即密码和其他信息(,我对此表示满意。

但是,即使我更改XML中的其他值,然后上传模板也无法使用。

我需要重新启动NIFI服务器吗?大概还有其他可以反映的坦帕特?

我唯一要在此模板中更改的是队列名称主机名。但是,如果我将其更改为XML模板并上传,则无法正常工作。

    <?xml version="1.0" encoding="UTF-8" standalone="yes"?>
<template encoding-version="1.2">
    <description></description>
    <groupId>6893964f-0161-1000-c252-8edd203653e6</groupId>
    <name>template1</name>
    <snippet>
        <processGroups>
            <id>e0bb9818-49e5-3194-0000-000000000000</id>
            <parentGroupId>62dd8ddb-07e2-3459-0000-000000000000</parentGroupId>
            <position>
                <x>0.0</x>
                <y>0.0</y>
            </position>
            <comments></comments>
            <contents>
                <processors>
                    <id>a2cb42ea-5e05-362d-0000-000000000000</id>
                    <parentGroupId>e0bb9818-49e5-3194-0000-000000000000</parentGroupId>
                    <position>
                        <x>414.0</x>
                        <y>174.0</y>
                    </position>
                    <bundle>
                        <artifact>nifi-amqp-nar</artifact>
                        <group>org.apache.nifi</group>
                        <version>1.5.0</version>
                    </bundle>
                    <config>
                        <bulletinLevel>WARN</bulletinLevel>
                        <comments></comments>
                        <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
                        <descriptors>
                            <entry>
                                <key>Queue</key>
                                <value>
                                    <name>Queue</name>
                                </value>
                            </entry>
                            <entry>
                                <key>Host Name</key>
                                <value>
                                    <name>Host Name</name>
                                </value>
                            </entry>
                            <entry>
                                <key>Port</key>
                                <value>
                                    <name>Port</name>
                                </value>
                            </entry>
                            <entry>
                                <key>Virtual Host</key>
                                <value>
                                    <name>Virtual Host</name>
                                </value>
                            </entry>
                            <entry>
                                <key>User Name</key>
                                <value>
                                    <name>User Name</name>
                                </value>
                            </entry>
                            <entry>
                                <key>Password</key>
                                <value>
                                    <name>Password</name>
                                </value>
                            </entry>
                            <entry>
                                <key>AMQP Version</key>
                                <value>
                                    <name>AMQP Version</name>
                                </value>
                            </entry>
                            <entry>
                                <key>ssl-context-service</key>
                                <value>
                                    <identifiesControllerService>org.apache.nifi.ssl.SSLContextService</identifiesControllerService>
                                    <name>ssl-context-service</name>
                                </value>
                            </entry>
                            <entry>
                                <key>cert-authentication</key>
                                <value>
                                    <name>cert-authentication</name>
                                </value>
                            </entry>
                            <entry>
                                <key>ssl-client-auth</key>
                                <value>
                                    <name>ssl-client-auth</name>
                                </value>
                            </entry>
                        </descriptors>
                        <executionNode>ALL</executionNode>
                        <lossTolerant>false</lossTolerant>
                        <penaltyDuration>30 sec</penaltyDuration>
                        <properties>
                            <entry>
                                <key>Queue</key>
                                <value>testq</value>
                            </entry>
                            <entry>
                                <key>Host Name</key>
                                <value>abcd.com</value>
                            </entry>
                            <entry>
                                <key>Port</key>
                                <value>5672</value>
                            </entry>
                            <entry>
                                <key>Virtual Host</key>
                            </entry>
                            <entry>
                                <key>User Name</key>
                                <value>gshah</value>
                            </entry>
                            <entry>
                                <key>Password</key>
                            </entry>
                            <entry>
                                <key>AMQP Version</key>
                                <value>0.9.1</value>
                            </entry>
                            <entry>
                                <key>ssl-context-service</key>
                            </entry>
                            <entry>
                                <key>cert-authentication</key>
                                <value>false</value>
                            </entry>
                            <entry>
                                <key>ssl-client-auth</key>
                                <value>REQUIRED</value>
                            </entry>
                        </properties>
                        <runDurationMillis>0</runDurationMillis>
                        <schedulingPeriod>0 sec</schedulingPeriod>
                        <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
                        <yieldDuration>1 sec</yieldDuration>
                    </config>
                    <name>ConsumeAMQP</name>
                    <relationships>
                        <autoTerminate>false</autoTerminate>
                        <name>success</name>
                    </relationships>
                    <state>STOPPED</state>
                    <style/>
                    <type>org.apache.nifi.amqp.processors.ConsumeAMQP</type>
                </processors>
            </contents>
            <name>Consumer</name>
            <variables/>
        </processGroups>
    </snippet>
    <timestamp>02/05/2018 23:22:10 EST</timestamp>
</template>

您可以使用NIFI注册表,非常适合您所需的内容。我建议您阅读本文,这确实很好地解释了如何部署不同的环境网。

我将讨论您必须自动部署的方法 使用NIFI促进多个环境之间的工作流程 注册表。我将讨论并演示您有两个选择 需要知道:

使用NIFI Toolkit 1.6.0
发布的NIFI CLI
Nipyapi Python库0.8.0

最新更新