Created
September 2, 2024 20:25
-
-
Save soenkeliebau/d9da107ccc1dcf0635f7f7066af618df to your computer and use it in GitHub Desktop.
import-waterlevel
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<?xml version="1.0" encoding="UTF-8" standalone="yes"?> | |
<template encoding-version="1.3"> | |
<description></description> | |
<groupId>af6f1311-0191-1000-9271-8e04c1826165</groupId> | |
<name>import-waterlevel</name> | |
<snippet> | |
<connections> | |
<id>02751ec7-92a8-36c3-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<versionedComponentId>02751ec7-92a8-36c3-821c-3f52202603f7</versionedComponentId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>1</backPressureObjectThreshold> | |
<destination> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>5be559ad-e255-3181-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
<versionedComponentId>5be559ad-e255-3181-a892-bfafd5800193</versionedComponentId> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute></loadBalancePartitionAttribute> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name></name> | |
<selectedRelationships>Response</selectedRelationships> | |
<source> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>3c8ee1e1-5ed5-34d1-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
<versionedComponentId>3c8ee1e1-5ed5-34d1-8191-d3295896a36d</versionedComponentId> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>0b60082a-20da-306d-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<versionedComponentId>0b60082a-20da-306d-801e-876d5a030eab</versionedComponentId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10</backPressureObjectThreshold> | |
<destination> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>dcc17c80-7492-3baf-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
<versionedComponentId>dcc17c80-7492-3baf-b512-7c7836a5f309</versionedComponentId> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute></loadBalancePartitionAttribute> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name></name> | |
<selectedRelationships>matched</selectedRelationships> | |
<source> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>b016c33d-7bc2-3a06-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
<versionedComponentId>b016c33d-7bc2-3a06-9867-ae062a3a9ea8</versionedComponentId> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>139b85df-354e-36a1-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>d82d7e5d-647d-35e5-0000-000000000000</id> | |
<type>FUNNEL</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute></loadBalancePartitionAttribute> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name></name> | |
<selectedRelationships>failure</selectedRelationships> | |
<source> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>d72bdef3-afb2-3243-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
<versionedComponentId>d72bdef3-afb2-3243-bd45-85fd5325b5e0</versionedComponentId> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>29450f1c-5d2b-3d7d-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>3baaf837-4003-3b40-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute></loadBalancePartitionAttribute> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name></name> | |
<selectedRelationships>Response</selectedRelationships> | |
<source> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>4c829980-49fa-3a45-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
<versionedComponentId>4c829980-49fa-3a45-a8c8-3712d57731b2</versionedComponentId> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>60b706c9-eec5-359d-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<versionedComponentId>60b706c9-eec5-359d-a418-5c21a46b53a7</versionedComponentId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>1</backPressureObjectThreshold> | |
<destination> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>e3541e25-c5a1-3ba7-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
<versionedComponentId>e3541e25-c5a1-3ba7-b6ec-f81b6961b249</versionedComponentId> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute></loadBalancePartitionAttribute> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name></name> | |
<selectedRelationships>merged</selectedRelationships> | |
<source> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>d72bdef3-afb2-3243-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
<versionedComponentId>d72bdef3-afb2-3243-bd45-85fd5325b5e0</versionedComponentId> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>80bae6f5-4168-3cc4-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>cf8a985d-19b7-36ac-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute></loadBalancePartitionAttribute> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name></name> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>18a472e5-a16d-3f89-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>834bc929-34d3-38d4-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<versionedComponentId>834bc929-34d3-38d4-811b-4b1538b82c62</versionedComponentId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10</backPressureObjectThreshold> | |
<destination> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>d25b4d75-7425-3372-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
<versionedComponentId>d25b4d75-7425-3372-b3fa-b7c5930a9afd</versionedComponentId> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute></loadBalancePartitionAttribute> | |
<loadBalanceStatus>LOAD_BALANCE_INACTIVE</loadBalanceStatus> | |
<loadBalanceStrategy>ROUND_ROBIN</loadBalanceStrategy> | |
<name></name> | |
<selectedRelationships>splits</selectedRelationships> | |
<source> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>841af892-1afb-38e1-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
<versionedComponentId>841af892-1afb-38e1-8df1-285672c8cce2</versionedComponentId> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>8d769092-b5ac-3691-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<versionedComponentId>8d769092-b5ac-3691-abcd-5e263444ec93</versionedComponentId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>2000</backPressureObjectThreshold> | |
<destination> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>d72bdef3-afb2-3243-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
<versionedComponentId>d72bdef3-afb2-3243-bd45-85fd5325b5e0</versionedComponentId> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute></loadBalancePartitionAttribute> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name></name> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>a9882099-7faa-316e-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
<versionedComponentId>a9882099-7faa-316e-96db-323da0f2cb44</versionedComponentId> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>9198c2a7-97ac-35e3-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<versionedComponentId>9198c2a7-97ac-35e3-88e5-bec63cb9192c</versionedComponentId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>1</backPressureObjectThreshold> | |
<destination> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>841af892-1afb-38e1-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
<versionedComponentId>841af892-1afb-38e1-8df1-285672c8cce2</versionedComponentId> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute></loadBalancePartitionAttribute> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name></name> | |
<selectedRelationships>Response</selectedRelationships> | |
<source> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>90106fb6-2708-3a48-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
<versionedComponentId>90106fb6-2708-3a48-86df-1019e55acdab</versionedComponentId> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>97c1dfa2-6a22-3c65-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<versionedComponentId>97c1dfa2-6a22-3c65-8f7c-a6d571a698e5</versionedComponentId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10</backPressureObjectThreshold> | |
<destination> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>b016c33d-7bc2-3a06-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
<versionedComponentId>b016c33d-7bc2-3a06-9867-ae062a3a9ea8</versionedComponentId> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute></loadBalancePartitionAttribute> | |
<loadBalanceStatus>LOAD_BALANCE_INACTIVE</loadBalanceStatus> | |
<loadBalanceStrategy>ROUND_ROBIN</loadBalanceStrategy> | |
<name></name> | |
<selectedRelationships>splits</selectedRelationships> | |
<source> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>5be559ad-e255-3181-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
<versionedComponentId>5be559ad-e255-3181-a892-bfafd5800193</versionedComponentId> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>9cb91248-7d77-3c9e-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>d72bdef3-afb2-3243-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
<versionedComponentId>d72bdef3-afb2-3243-bd45-85fd5325b5e0</versionedComponentId> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute></loadBalancePartitionAttribute> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name></name> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>0213239f-ccd1-31f6-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
<versionedComponentId>0213239f-ccd1-31f6-9ef9-0b5b2b0fc579</versionedComponentId> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>c0fe4da6-3049-3519-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<versionedComponentId>c0fe4da6-3049-3519-9156-098fa5edeeb8</versionedComponentId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10</backPressureObjectThreshold> | |
<destination> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>0213239f-ccd1-31f6-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
<versionedComponentId>0213239f-ccd1-31f6-9ef9-0b5b2b0fc579</versionedComponentId> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute></loadBalancePartitionAttribute> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name></name> | |
<selectedRelationships>Response</selectedRelationships> | |
<source> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>4580a96a-ad2e-36ea-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
<versionedComponentId>4580a96a-ad2e-36ea-b1ae-c0af21302f98</versionedComponentId> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>d09c4c4c-933a-3365-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>3142f62b-9219-3735-0000-000000000000</id> | |
<type>FUNNEL</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute></loadBalancePartitionAttribute> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name></name> | |
<selectedRelationships>failure</selectedRelationships> | |
<source> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>3baaf837-4003-3b40-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>d772375b-a6e6-3021-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<versionedComponentId>d772375b-a6e6-3021-98f9-a72fcc86419f</versionedComponentId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10</backPressureObjectThreshold> | |
<destination> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>4580a96a-ad2e-36ea-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
<versionedComponentId>4580a96a-ad2e-36ea-b1ae-c0af21302f98</versionedComponentId> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute></loadBalancePartitionAttribute> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name></name> | |
<selectedRelationships>matched</selectedRelationships> | |
<source> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>d25b4d75-7425-3372-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
<versionedComponentId>d25b4d75-7425-3372-b3fa-b7c5930a9afd</versionedComponentId> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>de15f1e6-1f87-30cf-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<versionedComponentId>de15f1e6-1f87-30cf-a568-eaaad6acf3bd</versionedComponentId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10</backPressureObjectThreshold> | |
<destination> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>a9882099-7faa-316e-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
<versionedComponentId>a9882099-7faa-316e-96db-323da0f2cb44</versionedComponentId> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute></loadBalancePartitionAttribute> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name></name> | |
<selectedRelationships>Response</selectedRelationships> | |
<source> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>dcc17c80-7492-3baf-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
<versionedComponentId>dcc17c80-7492-3baf-b512-7c7836a5f309</versionedComponentId> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>f5ce4fff-3464-3760-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>18a472e5-a16d-3f89-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> | |
<loadBalancePartitionAttribute></loadBalancePartitionAttribute> | |
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> | |
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> | |
<name></name> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>8f337141-9a3e-3b48-0000-000000000000</groupId> | |
<id>3baaf837-4003-3b40-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<controllerServices> | |
<id>175d68ec-57f4-30c9-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<versionedComponentId>175d68ec-57f4-30c9-8ffe-7c78bfccd411</versionedComponentId> | |
<bulletinLevel>WARN</bulletinLevel> | |
<bundle> | |
<artifact>nifi-kerberos-credentials-service-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.27.0</version> | |
</bundle> | |
<comments></comments> | |
<descriptors> | |
<entry> | |
<key>Kerberos Keytab</key> | |
<value> | |
<name>Kerberos Keytab</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Kerberos Principal</key> | |
<value> | |
<name>Kerberos Principal</name> | |
</value> | |
</entry> | |
</descriptors> | |
<name>KeytabCredentialsService</name> | |
<persistsState>false</persistsState> | |
<properties> | |
<entry> | |
<key>Kerberos Keytab</key> | |
<value>/stackable/kerberos/keytab</value> | |
</entry> | |
<entry> | |
<key>Kerberos Principal</key> | |
<value>nifi/[email protected]</value> | |
</entry> | |
</properties> | |
<state>ENABLED</state> | |
<type>org.apache.nifi.kerberos.KeytabCredentialsService</type> | |
</controllerServices> | |
<controllerServices> | |
<id>2b513981-28e9-344b-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<versionedComponentId>2b513981-28e9-344b-a9c6-098d46bfb901</versionedComponentId> | |
<bulletinLevel>WARN</bulletinLevel> | |
<bundle> | |
<artifact>nifi-record-serialization-services-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.27.0</version> | |
</bundle> | |
<descriptors> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value> | |
<name>schema-access-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
<value> | |
<dependencies> | |
<dependentValues>confluent-encoded</dependentValues> | |
<dependentValues>schema-name</dependentValues> | |
<dependentValues>hwx-schema-ref-attributes</dependentValues> | |
<dependentValues>hwx-content-encoded-schema</dependentValues> | |
<propertyName>schema-access-strategy</propertyName> | |
</dependencies> | |
<identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService> | |
<name>schema-registry</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value> | |
<dependencies> | |
<dependentValues>schema-name</dependentValues> | |
<propertyName>schema-access-strategy</propertyName> | |
</dependencies> | |
<name>schema-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-version</key> | |
<value> | |
<dependencies> | |
<dependentValues>schema-name</dependentValues> | |
<propertyName>schema-access-strategy</propertyName> | |
</dependencies> | |
<name>schema-version</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-branch</key> | |
<value> | |
<dependencies> | |
<dependentValues>schema-name</dependentValues> | |
<propertyName>schema-access-strategy</propertyName> | |
</dependencies> | |
<name>schema-branch</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value> | |
<dependencies> | |
<dependentValues>schema-text-property</dependentValues> | |
<propertyName>schema-access-strategy</propertyName> | |
</dependencies> | |
<name>schema-text</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-inference-cache</key> | |
<value> | |
<dependencies> | |
<dependentValues>infer-schema</dependentValues> | |
<propertyName>schema-access-strategy</propertyName> | |
</dependencies> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSchemaCacheService</identifiesControllerService> | |
<name>schema-inference-cache</name> | |
</value> | |
</entry> | |
<entry> | |
<key>starting-field-strategy</key> | |
<value> | |
<name>starting-field-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>starting-field-name</key> | |
<value> | |
<dependencies> | |
<dependentValues>NESTED_FIELD</dependentValues> | |
<propertyName>starting-field-strategy</propertyName> | |
</dependencies> | |
<name>starting-field-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-application-strategy</key> | |
<value> | |
<dependencies> | |
<dependentValues>confluent-encoded</dependentValues> | |
<dependentValues>schema-name</dependentValues> | |
<dependentValues>schema-text-property</dependentValues> | |
<dependentValues>hwx-schema-ref-attributes</dependentValues> | |
<dependentValues>hwx-content-encoded-schema</dependentValues> | |
<propertyName>schema-access-strategy</propertyName> | |
</dependencies> | |
<dependencies> | |
<dependentValues>NESTED_FIELD</dependentValues> | |
<propertyName>starting-field-strategy</propertyName> | |
</dependencies> | |
<name>schema-application-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Max String Length</key> | |
<value> | |
<name>Max String Length</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Allow Comments</key> | |
<value> | |
<name>Allow Comments</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Date Format</key> | |
<value> | |
<name>Date Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Time Format</key> | |
<value> | |
<name>Time Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Timestamp Format</key> | |
<value> | |
<name>Timestamp Format</name> | |
</value> | |
</entry> | |
</descriptors> | |
<name>JsonTreeReader</name> | |
<persistsState>false</persistsState> | |
<properties> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value>infer-schema</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value>${schema.name}</value> | |
</entry> | |
<entry> | |
<key>schema-version</key> | |
</entry> | |
<entry> | |
<key>schema-branch</key> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value>${avro.schema}</value> | |
</entry> | |
<entry> | |
<key>schema-inference-cache</key> | |
</entry> | |
<entry> | |
<key>starting-field-strategy</key> | |
<value>ROOT_NODE</value> | |
</entry> | |
<entry> | |
<key>starting-field-name</key> | |
</entry> | |
<entry> | |
<key>schema-application-strategy</key> | |
<value>SELECTED_PART</value> | |
</entry> | |
<entry> | |
<key>Max String Length</key> | |
<value>20 MB</value> | |
</entry> | |
<entry> | |
<key>Allow Comments</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Date Format</key> | |
</entry> | |
<entry> | |
<key>Time Format</key> | |
</entry> | |
<entry> | |
<key>Timestamp Format</key> | |
</entry> | |
</properties> | |
<state>ENABLED</state> | |
<type>org.apache.nifi.json.JsonTreeReader</type> | |
</controllerServices> | |
<controllerServices> | |
<id>2b81a8e5-eec1-3f15-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<versionedComponentId>2b81a8e5-eec1-3f15-9cef-ec8061cddc3a</versionedComponentId> | |
<bulletinLevel>WARN</bulletinLevel> | |
<bundle> | |
<artifact>nifi-record-serialization-services-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.27.0</version> | |
</bundle> | |
<descriptors> | |
<entry> | |
<key>Schema Write Strategy</key> | |
<value> | |
<name>Schema Write Strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-cache</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSchemaCacheService</identifiesControllerService> | |
<name>schema-cache</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-protocol-version</key> | |
<value> | |
<dependencies> | |
<dependentValues>hwx-schema-ref-attributes</dependentValues> | |
<dependentValues>hwx-content-encoded-schema</dependentValues> | |
<propertyName>Schema Write Strategy</propertyName> | |
</dependencies> | |
<name>schema-protocol-version</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value> | |
<name>schema-access-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
<value> | |
<dependencies> | |
<dependentValues>confluent-encoded</dependentValues> | |
<dependentValues>schema-name</dependentValues> | |
<dependentValues>hwx-schema-ref-attributes</dependentValues> | |
<dependentValues>hwx-content-encoded-schema</dependentValues> | |
<propertyName>schema-access-strategy</propertyName> | |
</dependencies> | |
<identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService> | |
<name>schema-registry</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value> | |
<dependencies> | |
<dependentValues>schema-name</dependentValues> | |
<propertyName>schema-access-strategy</propertyName> | |
</dependencies> | |
<name>schema-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-version</key> | |
<value> | |
<dependencies> | |
<dependentValues>schema-name</dependentValues> | |
<propertyName>schema-access-strategy</propertyName> | |
</dependencies> | |
<name>schema-version</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-branch</key> | |
<value> | |
<dependencies> | |
<dependentValues>schema-name</dependentValues> | |
<propertyName>schema-access-strategy</propertyName> | |
</dependencies> | |
<name>schema-branch</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value> | |
<dependencies> | |
<dependentValues>schema-text-property</dependentValues> | |
<propertyName>schema-access-strategy</propertyName> | |
</dependencies> | |
<name>schema-text</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Date Format</key> | |
<value> | |
<name>Date Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Time Format</key> | |
<value> | |
<name>Time Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Timestamp Format</key> | |
<value> | |
<name>Timestamp Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Pretty Print JSON</key> | |
<value> | |
<name>Pretty Print JSON</name> | |
</value> | |
</entry> | |
<entry> | |
<key>suppress-nulls</key> | |
<value> | |
<name>suppress-nulls</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Allow Scientific Notation</key> | |
<value> | |
<name>Allow Scientific Notation</name> | |
</value> | |
</entry> | |
<entry> | |
<key>output-grouping</key> | |
<value> | |
<name>output-grouping</name> | |
</value> | |
</entry> | |
<entry> | |
<key>compression-format</key> | |
<value> | |
<name>compression-format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>compression-level</key> | |
<value> | |
<dependencies> | |
<dependentValues>gzip</dependentValues> | |
<propertyName>compression-format</propertyName> | |
</dependencies> | |
<name>compression-level</name> | |
</value> | |
</entry> | |
</descriptors> | |
<name>JsonRecordSetWriter</name> | |
<persistsState>false</persistsState> | |
<properties> | |
<entry> | |
<key>Schema Write Strategy</key> | |
<value>no-schema</value> | |
</entry> | |
<entry> | |
<key>schema-cache</key> | |
</entry> | |
<entry> | |
<key>schema-protocol-version</key> | |
<value>1</value> | |
</entry> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value>inherit-record-schema</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value>${schema.name}</value> | |
</entry> | |
<entry> | |
<key>schema-version</key> | |
</entry> | |
<entry> | |
<key>schema-branch</key> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value>${avro.schema}</value> | |
</entry> | |
<entry> | |
<key>Date Format</key> | |
</entry> | |
<entry> | |
<key>Time Format</key> | |
</entry> | |
<entry> | |
<key>Timestamp Format</key> | |
</entry> | |
<entry> | |
<key>Pretty Print JSON</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>suppress-nulls</key> | |
<value>never-suppress</value> | |
</entry> | |
<entry> | |
<key>Allow Scientific Notation</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>output-grouping</key> | |
<value>output-array</value> | |
</entry> | |
<entry> | |
<key>compression-format</key> | |
<value>none</value> | |
</entry> | |
<entry> | |
<key>compression-level</key> | |
<value>1</value> | |
</entry> | |
</properties> | |
<state>ENABLED</state> | |
<type>org.apache.nifi.json.JsonRecordSetWriter</type> | |
</controllerServices> | |
<controllerServices> | |
<id>7d161aec-a83d-3493-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<versionedComponentId>7d161aec-a83d-3493-9681-dbd55d878992</versionedComponentId> | |
<bulletinLevel>WARN</bulletinLevel> | |
<bundle> | |
<artifact>nifi-parquet-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.27.0</version> | |
</bundle> | |
<comments></comments> | |
<descriptors> | |
<entry> | |
<key>Schema Write Strategy</key> | |
<value> | |
<name>Schema Write Strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-cache</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSchemaCacheService</identifiesControllerService> | |
<name>schema-cache</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-protocol-version</key> | |
<value> | |
<dependencies> | |
<dependentValues>hwx-schema-ref-attributes</dependentValues> | |
<dependentValues>hwx-content-encoded-schema</dependentValues> | |
<propertyName>Schema Write Strategy</propertyName> | |
</dependencies> | |
<name>schema-protocol-version</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value> | |
<name>schema-access-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
<value> | |
<dependencies> | |
<dependentValues>confluent-encoded</dependentValues> | |
<dependentValues>schema-name</dependentValues> | |
<dependentValues>hwx-schema-ref-attributes</dependentValues> | |
<dependentValues>hwx-content-encoded-schema</dependentValues> | |
<propertyName>schema-access-strategy</propertyName> | |
</dependencies> | |
<identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService> | |
<name>schema-registry</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value> | |
<dependencies> | |
<dependentValues>schema-name</dependentValues> | |
<propertyName>schema-access-strategy</propertyName> | |
</dependencies> | |
<name>schema-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-version</key> | |
<value> | |
<dependencies> | |
<dependentValues>schema-name</dependentValues> | |
<propertyName>schema-access-strategy</propertyName> | |
</dependencies> | |
<name>schema-version</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-branch</key> | |
<value> | |
<dependencies> | |
<dependentValues>schema-name</dependentValues> | |
<propertyName>schema-access-strategy</propertyName> | |
</dependencies> | |
<name>schema-branch</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value> | |
<dependencies> | |
<dependentValues>schema-text-property</dependentValues> | |
<propertyName>schema-access-strategy</propertyName> | |
</dependencies> | |
<name>schema-text</name> | |
</value> | |
</entry> | |
<entry> | |
<key>cache-size</key> | |
<value> | |
<name>cache-size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>compression-type</key> | |
<value> | |
<name>compression-type</name> | |
</value> | |
</entry> | |
<entry> | |
<key>row-group-size</key> | |
<value> | |
<name>row-group-size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>page-size</key> | |
<value> | |
<name>page-size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>dictionary-page-size</key> | |
<value> | |
<name>dictionary-page-size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max-padding-size</key> | |
<value> | |
<name>max-padding-size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>enable-dictionary-encoding</key> | |
<value> | |
<name>enable-dictionary-encoding</name> | |
</value> | |
</entry> | |
<entry> | |
<key>enable-validation</key> | |
<value> | |
<name>enable-validation</name> | |
</value> | |
</entry> | |
<entry> | |
<key>writer-version</key> | |
<value> | |
<name>writer-version</name> | |
</value> | |
</entry> | |
<entry> | |
<key>avro-write-old-list-structure</key> | |
<value> | |
<name>avro-write-old-list-structure</name> | |
</value> | |
</entry> | |
<entry> | |
<key>avro-add-list-element-records</key> | |
<value> | |
<name>avro-add-list-element-records</name> | |
</value> | |
</entry> | |
<entry> | |
<key>int96-fields</key> | |
<value> | |
<name>int96-fields</name> | |
</value> | |
</entry> | |
</descriptors> | |
<name>ParquetRecordSetWriter</name> | |
<persistsState>false</persistsState> | |
<properties> | |
<entry> | |
<key>Schema Write Strategy</key> | |
<value>no-schema</value> | |
</entry> | |
<entry> | |
<key>schema-cache</key> | |
</entry> | |
<entry> | |
<key>schema-protocol-version</key> | |
<value>1</value> | |
</entry> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value>inherit-record-schema</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value>${schema.name}</value> | |
</entry> | |
<entry> | |
<key>schema-version</key> | |
</entry> | |
<entry> | |
<key>schema-branch</key> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value>${avro.schema}</value> | |
</entry> | |
<entry> | |
<key>cache-size</key> | |
<value>1000</value> | |
</entry> | |
<entry> | |
<key>compression-type</key> | |
<value>UNCOMPRESSED</value> | |
</entry> | |
<entry> | |
<key>row-group-size</key> | |
</entry> | |
<entry> | |
<key>page-size</key> | |
</entry> | |
<entry> | |
<key>dictionary-page-size</key> | |
</entry> | |
<entry> | |
<key>max-padding-size</key> | |
</entry> | |
<entry> | |
<key>enable-dictionary-encoding</key> | |
</entry> | |
<entry> | |
<key>enable-validation</key> | |
</entry> | |
<entry> | |
<key>writer-version</key> | |
</entry> | |
<entry> | |
<key>avro-write-old-list-structure</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>avro-add-list-element-records</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>int96-fields</key> | |
</entry> | |
</properties> | |
<state>ENABLED</state> | |
<type>org.apache.nifi.parquet.ParquetRecordSetWriter</type> | |
</controllerServices> | |
<funnels> | |
<id>3142f62b-9219-3735-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<position> | |
<x>0.0</x> | |
<y>316.0</y> | |
</position> | |
</funnels> | |
<funnels> | |
<id>d82d7e5d-647d-35e5-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<position> | |
<x>1712.0</x> | |
<y>1412.0</y> | |
</position> | |
</funnels> | |
<labels> | |
<id>01901688-c9ac-3776-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<position> | |
<x>390.0</x> | |
<y>40.0</y> | |
</position> | |
<versionedComponentId>01901688-c9ac-3776-aa4e-68117fb074ce</versionedComponentId> | |
<height>24.0</height> | |
<label>Ingest station records</label> | |
<style> | |
<entry> | |
<key>font-size</key> | |
<value>12px</value> | |
</entry> | |
</style> | |
<width>152.0</width> | |
<zIndex>0</zIndex> | |
</labels> | |
<labels> | |
<id>1e8a9269-2d84-323a-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<position> | |
<x>390.0</x> | |
<y>0.0</y> | |
</position> | |
<versionedComponentId>1e8a9269-2d84-323a-9e52-1295f8995b5a</versionedComponentId> | |
<height>24.0</height> | |
<label>Water levels data</label> | |
<style> | |
<entry> | |
<key>font-size</key> | |
<value>12px</value> | |
</entry> | |
</style> | |
<width>1104.0</width> | |
<zIndex>0</zIndex> | |
</labels> | |
<labels> | |
<id>3ba2b3bc-1a0b-38c4-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<position> | |
<x>1142.0</x> | |
<y>40.0</y> | |
</position> | |
<versionedComponentId>3ba2b3bc-1a0b-38c4-9a3c-8bdc4a17fa11</versionedComponentId> | |
<height>24.0</height> | |
<label>Stream real-time data</label> | |
<style> | |
<entry> | |
<key>font-size</key> | |
<value>12px</value> | |
</entry> | |
</style> | |
<width>152.0</width> | |
<zIndex>0</zIndex> | |
</labels> | |
<labels> | |
<id>f16a197c-3439-3994-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<position> | |
<x>766.0</x> | |
<y>40.0</y> | |
</position> | |
<versionedComponentId>f16a197c-3439-3994-8736-5ff037e6c3e6</versionedComponentId> | |
<height>24.0</height> | |
<label>Ingest historic data</label> | |
<style> | |
<entry> | |
<key>font-size</key> | |
<value>12px</value> | |
</entry> | |
</style> | |
<width>152.0</width> | |
<zIndex>0</zIndex> | |
</labels> | |
<processors> | |
<id>0213239f-ccd1-31f6-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<position> | |
<x>766.0</x> | |
<y>1016.0</y> | |
</position> | |
<versionedComponentId>0213239f-ccd1-31f6-9ef9-0b5b2b0fc579</versionedComponentId> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.27.0</version> | |
</bundle> | |
<config> | |
<backoffMechanism>PENALIZE_FLOWFILE</backoffMechanism> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>jolt-transform</key> | |
<value> | |
<name>jolt-transform</name> | |
</value> | |
</entry> | |
<entry> | |
<key>jolt-custom-class</key> | |
<value> | |
<dependencies> | |
<dependentValues>jolt-transform-custom</dependentValues> | |
<propertyName>jolt-transform</propertyName> | |
</dependencies> | |
<name>jolt-custom-class</name> | |
</value> | |
</entry> | |
<entry> | |
<key>jolt-custom-modules</key> | |
<value> | |
<dependencies> | |
<dependentValues>jolt-transform-custom</dependentValues> | |
<propertyName>jolt-transform</propertyName> | |
</dependencies> | |
<name>jolt-custom-modules</name> | |
</value> | |
</entry> | |
<entry> | |
<key>jolt-spec</key> | |
<value> | |
<name>jolt-spec</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Transform Cache Size</key> | |
<value> | |
<name>Transform Cache Size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>pretty_print</key> | |
<value> | |
<name>pretty_print</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Max String Length</key> | |
<value> | |
<name>Max String Length</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<maxBackoffPeriod>10 mins</maxBackoffPeriod> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>jolt-transform</key> | |
<value>jolt-transform-chain</value> | |
</entry> | |
<entry> | |
<key>jolt-custom-class</key> | |
</entry> | |
<entry> | |
<key>jolt-custom-modules</key> | |
</entry> | |
<entry> | |
<key>jolt-spec</key> | |
<value>[ | |
{ | |
"operation": "default", | |
"spec": { | |
"*": { | |
"station_uuid": "${station_uuid}" | |
} | |
} | |
} | |
] | |
</value> | |
</entry> | |
<entry> | |
<key>Transform Cache Size</key> | |
<value>1</value> | |
</entry> | |
<entry> | |
<key>pretty_print</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Max String Length</key> | |
<value>20 MB</value> | |
</entry> | |
</properties> | |
<retryCount>10</retryCount> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>Add station_uuid</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
<retry>false</retry> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.JoltTransformJSON</type> | |
</processors> | |
<processors> | |
<id>18a472e5-a16d-3f89-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<position> | |
<x>376.0</x> | |
<y>556.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-update-attribute-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.27.0</version> | |
</bundle> | |
<config> | |
<backoffMechanism>PENALIZE_FLOWFILE</backoffMechanism> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>Delete Attributes Expression</key> | |
<value> | |
<name>Delete Attributes Expression</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Store State</key> | |
<value> | |
<name>Store State</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Stateful Variables Initial Value</key> | |
<value> | |
<name>Stateful Variables Initial Value</name> | |
</value> | |
</entry> | |
<entry> | |
<key>canonical-value-lookup-cache-size</key> | |
<value> | |
<name>canonical-value-lookup-cache-size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>filename</key> | |
<value> | |
<name>filename</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<maxBackoffPeriod>10 mins</maxBackoffPeriod> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>Delete Attributes Expression</key> | |
</entry> | |
<entry> | |
<key>Store State</key> | |
<value>Do not store state</value> | |
</entry> | |
<entry> | |
<key>Stateful Variables Initial Value</key> | |
</entry> | |
<entry> | |
<key>canonical-value-lookup-cache-size</key> | |
<value>100</value> | |
</entry> | |
<entry> | |
<key>filename</key> | |
<value>stations.parquet</value> | |
</entry> | |
</properties> | |
<retryCount>10</retryCount> | |
<runDurationMillis>25</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>UpdateAttribute</name> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
<retry>false</retry> | |
</relationships> | |
<state>RUNNING</state> | |
<style/> | |
<type>org.apache.nifi.processors.attributes.UpdateAttribute</type> | |
</processors> | |
<processors> | |
<id>3baaf837-4003-3b40-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<position> | |
<x>392.0</x> | |
<y>316.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.27.0</version> | |
</bundle> | |
<config> | |
<backoffMechanism>PENALIZE_FLOWFILE</backoffMechanism> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>record-reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>record-reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>record-writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>include-zero-record-flowfiles</key> | |
<value> | |
<name>include-zero-record-flowfiles</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<maxBackoffPeriod>10 mins</maxBackoffPeriod> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>record-reader</key> | |
<value>2b513981-28e9-344b-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value>7d161aec-a83d-3493-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>include-zero-record-flowfiles</key> | |
<value>true</value> | |
</entry> | |
</properties> | |
<retryCount>10</retryCount> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>ConvertRecord</name> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>failure</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
<retry>false</retry> | |
</relationships> | |
<state>RUNNING</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.ConvertRecord</type> | |
</processors> | |
<processors> | |
<id>3c8ee1e1-5ed5-34d1-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<position> | |
<x>1142.0</x> | |
<y>72.0</y> | |
</position> | |
<versionedComponentId>3c8ee1e1-5ed5-34d1-8191-d3295896a36d</versionedComponentId> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.27.0</version> | |
</bundle> | |
<config> | |
<backoffMechanism>PENALIZE_FLOWFILE</backoffMechanism> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>HTTP Method</key> | |
<value> | |
<name>HTTP Method</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Remote URL</key> | |
<value> | |
<name>Remote URL</name> | |
</value> | |
</entry> | |
<entry> | |
<key>disable-http2</key> | |
<value> | |
<name>disable-http2</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>Connection Timeout</key> | |
<value> | |
<name>Connection Timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Read Timeout</key> | |
<value> | |
<name>Read Timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Socket Write Timeout</key> | |
<value> | |
<name>Socket Write Timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>idle-timeout</key> | |
<value> | |
<name>idle-timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max-idle-connections</key> | |
<value> | |
<name>max-idle-connections</name> | |
</value> | |
</entry> | |
<entry> | |
<key>proxy-configuration-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.proxy.ProxyConfigurationService</identifiesControllerService> | |
<name>proxy-configuration-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Proxy Host</key> | |
<value> | |
<name>Proxy Host</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Proxy Port</key> | |
<value> | |
<dependencies> | |
<propertyName>Proxy Host</propertyName> | |
</dependencies> | |
<name>Proxy Port</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Proxy Type</key> | |
<value> | |
<dependencies> | |
<propertyName>Proxy Host</propertyName> | |
</dependencies> | |
<name>Proxy Type</name> | |
</value> | |
</entry> | |
<entry> | |
<key>invokehttp-proxy-user</key> | |
<value> | |
<dependencies> | |
<propertyName>Proxy Host</propertyName> | |
</dependencies> | |
<name>invokehttp-proxy-user</name> | |
</value> | |
</entry> | |
<entry> | |
<key>invokehttp-proxy-password</key> | |
<value> | |
<dependencies> | |
<propertyName>Proxy Host</propertyName> | |
</dependencies> | |
<name>invokehttp-proxy-password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>oauth2-access-token-provider</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.oauth2.OAuth2AccessTokenProvider</identifiesControllerService> | |
<name>oauth2-access-token-provider</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Basic Authentication Username</key> | |
<value> | |
<name>Basic Authentication Username</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Basic Authentication Password</key> | |
<value> | |
<name>Basic Authentication Password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Digest Authentication</key> | |
<value> | |
<dependencies> | |
<propertyName>Basic Authentication Username</propertyName> | |
</dependencies> | |
<name>Digest Authentication</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Penalize on "No Retry"</key> | |
<value> | |
<name>Penalize on "No Retry"</name> | |
</value> | |
</entry> | |
<entry> | |
<key>send-message-body</key> | |
<value> | |
<dependencies> | |
<dependentValues>POST</dependentValues> | |
<dependentValues>PATCH</dependentValues> | |
<dependentValues>PUT</dependentValues> | |
<propertyName>HTTP Method</propertyName> | |
</dependencies> | |
<name>send-message-body</name> | |
</value> | |
</entry> | |
<entry> | |
<key>form-body-form-name</key> | |
<value> | |
<dependencies> | |
<dependentValues>true</dependentValues> | |
<propertyName>send-message-body</propertyName> | |
</dependencies> | |
<name>form-body-form-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>set-form-filename</key> | |
<value> | |
<dependencies> | |
<propertyName>form-body-form-name</propertyName> | |
</dependencies> | |
<name>set-form-filename</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Use Chunked Encoding</key> | |
<value> | |
<dependencies> | |
<dependentValues>POST</dependentValues> | |
<dependentValues>PATCH</dependentValues> | |
<dependentValues>PUT</dependentValues> | |
<propertyName>HTTP Method</propertyName> | |
</dependencies> | |
<name>Use Chunked Encoding</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Content-Encoding</key> | |
<value> | |
<dependencies> | |
<dependentValues>POST</dependentValues> | |
<dependentValues>PATCH</dependentValues> | |
<dependentValues>PUT</dependentValues> | |
<propertyName>HTTP Method</propertyName> | |
</dependencies> | |
<name>Content-Encoding</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Content-Type</key> | |
<value> | |
<dependencies> | |
<dependentValues>POST</dependentValues> | |
<dependentValues>PATCH</dependentValues> | |
<dependentValues>PUT</dependentValues> | |
<propertyName>HTTP Method</propertyName> | |
</dependencies> | |
<name>Content-Type</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Include Date Header</key> | |
<value> | |
<name>Include Date Header</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Attributes to Send</key> | |
<value> | |
<name>Attributes to Send</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Useragent</key> | |
<value> | |
<name>Useragent</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Put Response Body In Attribute</key> | |
<value> | |
<name>Put Response Body In Attribute</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Max Length To Put In Attribute</key> | |
<value> | |
<dependencies> | |
<propertyName>Put Response Body In Attribute</propertyName> | |
</dependencies> | |
<name>Max Length To Put In Attribute</name> | |
</value> | |
</entry> | |
<entry> | |
<key>ignore-response-content</key> | |
<value> | |
<name>ignore-response-content</name> | |
</value> | |
</entry> | |
<entry> | |
<key>use-etag</key> | |
<value> | |
<name>use-etag</name> | |
</value> | |
</entry> | |
<entry> | |
<key>etag-max-cache-size</key> | |
<value> | |
<dependencies> | |
<dependentValues>true</dependentValues> | |
<propertyName>use-etag</propertyName> | |
</dependencies> | |
<name>etag-max-cache-size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>cookie-strategy</key> | |
<value> | |
<name>cookie-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Always Output Response</key> | |
<value> | |
<name>Always Output Response</name> | |
</value> | |
</entry> | |
<entry> | |
<key>flow-file-naming-strategy</key> | |
<value> | |
<name>flow-file-naming-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Add Response Headers to Request</key> | |
<value> | |
<name>Add Response Headers to Request</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Follow Redirects</key> | |
<value> | |
<name>Follow Redirects</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>PRIMARY</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<maxBackoffPeriod>10 mins</maxBackoffPeriod> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>HTTP Method</key> | |
<value>GET</value> | |
</entry> | |
<entry> | |
<key>Remote URL</key> | |
<value>https://www.pegelonline.wsv.de/webservices/rest-api/v2/stations.json</value> | |
</entry> | |
<entry> | |
<key>disable-http2</key> | |
<value>False</value> | |
</entry> | |
<entry> | |
<key>SSL Context Service</key> | |
</entry> | |
<entry> | |
<key>Connection Timeout</key> | |
<value>5 secs</value> | |
</entry> | |
<entry> | |
<key>Read Timeout</key> | |
<value>15 secs</value> | |
</entry> | |
<entry> | |
<key>Socket Write Timeout</key> | |
<value>15 secs</value> | |
</entry> | |
<entry> | |
<key>idle-timeout</key> | |
<value>5 mins</value> | |
</entry> | |
<entry> | |
<key>max-idle-connections</key> | |
<value>5</value> | |
</entry> | |
<entry> | |
<key>proxy-configuration-service</key> | |
</entry> | |
<entry> | |
<key>Proxy Host</key> | |
</entry> | |
<entry> | |
<key>Proxy Port</key> | |
</entry> | |
<entry> | |
<key>Proxy Type</key> | |
<value>http</value> | |
</entry> | |
<entry> | |
<key>invokehttp-proxy-user</key> | |
</entry> | |
<entry> | |
<key>invokehttp-proxy-password</key> | |
</entry> | |
<entry> | |
<key>oauth2-access-token-provider</key> | |
</entry> | |
<entry> | |
<key>Basic Authentication Username</key> | |
</entry> | |
<entry> | |
<key>Basic Authentication Password</key> | |
</entry> | |
<entry> | |
<key>Digest Authentication</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Penalize on "No Retry"</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>send-message-body</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>form-body-form-name</key> | |
</entry> | |
<entry> | |
<key>set-form-filename</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>Use Chunked Encoding</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Content-Encoding</key> | |
<value>DISABLED</value> | |
</entry> | |
<entry> | |
<key>Content-Type</key> | |
<value>${mime.type}</value> | |
</entry> | |
<entry> | |
<key>Include Date Header</key> | |
<value>True</value> | |
</entry> | |
<entry> | |
<key>Attributes to Send</key> | |
</entry> | |
<entry> | |
<key>Useragent</key> | |
</entry> | |
<entry> | |
<key>Put Response Body In Attribute</key> | |
</entry> | |
<entry> | |
<key>Max Length To Put In Attribute</key> | |
<value>256</value> | |
</entry> | |
<entry> | |
<key>ignore-response-content</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>use-etag</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>etag-max-cache-size</key> | |
<value>10MB</value> | |
</entry> | |
<entry> | |
<key>cookie-strategy</key> | |
<value>DISABLED</value> | |
</entry> | |
<entry> | |
<key>Always Output Response</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>flow-file-naming-strategy</key> | |
<value>RANDOM</value> | |
</entry> | |
<entry> | |
<key>Add Response Headers to Request</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Follow Redirects</key> | |
<value>True</value> | |
</entry> | |
</properties> | |
<retryCount>10</retryCount> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>15 m</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>Get station list</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>Failure</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>No Retry</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>Original</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>Response</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>Retry</name> | |
<retry>false</retry> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.InvokeHTTP</type> | |
</processors> | |
<processors> | |
<id>4580a96a-ad2e-36ea-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<position> | |
<x>766.0</x> | |
<y>792.0</y> | |
</position> | |
<versionedComponentId>4580a96a-ad2e-36ea-b1ae-c0af21302f98</versionedComponentId> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.27.0</version> | |
</bundle> | |
<config> | |
<backoffMechanism>PENALIZE_FLOWFILE</backoffMechanism> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>HTTP Method</key> | |
<value> | |
<name>HTTP Method</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Remote URL</key> | |
<value> | |
<name>Remote URL</name> | |
</value> | |
</entry> | |
<entry> | |
<key>disable-http2</key> | |
<value> | |
<name>disable-http2</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>Connection Timeout</key> | |
<value> | |
<name>Connection Timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Read Timeout</key> | |
<value> | |
<name>Read Timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Socket Write Timeout</key> | |
<value> | |
<name>Socket Write Timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>idle-timeout</key> | |
<value> | |
<name>idle-timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max-idle-connections</key> | |
<value> | |
<name>max-idle-connections</name> | |
</value> | |
</entry> | |
<entry> | |
<key>proxy-configuration-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.proxy.ProxyConfigurationService</identifiesControllerService> | |
<name>proxy-configuration-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Proxy Host</key> | |
<value> | |
<name>Proxy Host</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Proxy Port</key> | |
<value> | |
<dependencies> | |
<propertyName>Proxy Host</propertyName> | |
</dependencies> | |
<name>Proxy Port</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Proxy Type</key> | |
<value> | |
<dependencies> | |
<propertyName>Proxy Host</propertyName> | |
</dependencies> | |
<name>Proxy Type</name> | |
</value> | |
</entry> | |
<entry> | |
<key>invokehttp-proxy-user</key> | |
<value> | |
<dependencies> | |
<propertyName>Proxy Host</propertyName> | |
</dependencies> | |
<name>invokehttp-proxy-user</name> | |
</value> | |
</entry> | |
<entry> | |
<key>invokehttp-proxy-password</key> | |
<value> | |
<dependencies> | |
<propertyName>Proxy Host</propertyName> | |
</dependencies> | |
<name>invokehttp-proxy-password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>oauth2-access-token-provider</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.oauth2.OAuth2AccessTokenProvider</identifiesControllerService> | |
<name>oauth2-access-token-provider</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Basic Authentication Username</key> | |
<value> | |
<name>Basic Authentication Username</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Basic Authentication Password</key> | |
<value> | |
<name>Basic Authentication Password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Digest Authentication</key> | |
<value> | |
<dependencies> | |
<propertyName>Basic Authentication Username</propertyName> | |
</dependencies> | |
<name>Digest Authentication</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Penalize on "No Retry"</key> | |
<value> | |
<name>Penalize on "No Retry"</name> | |
</value> | |
</entry> | |
<entry> | |
<key>send-message-body</key> | |
<value> | |
<dependencies> | |
<dependentValues>POST</dependentValues> | |
<dependentValues>PATCH</dependentValues> | |
<dependentValues>PUT</dependentValues> | |
<propertyName>HTTP Method</propertyName> | |
</dependencies> | |
<name>send-message-body</name> | |
</value> | |
</entry> | |
<entry> | |
<key>form-body-form-name</key> | |
<value> | |
<dependencies> | |
<dependentValues>true</dependentValues> | |
<propertyName>send-message-body</propertyName> | |
</dependencies> | |
<name>form-body-form-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>set-form-filename</key> | |
<value> | |
<dependencies> | |
<propertyName>form-body-form-name</propertyName> | |
</dependencies> | |
<name>set-form-filename</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Use Chunked Encoding</key> | |
<value> | |
<dependencies> | |
<dependentValues>POST</dependentValues> | |
<dependentValues>PATCH</dependentValues> | |
<dependentValues>PUT</dependentValues> | |
<propertyName>HTTP Method</propertyName> | |
</dependencies> | |
<name>Use Chunked Encoding</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Content-Encoding</key> | |
<value> | |
<dependencies> | |
<dependentValues>POST</dependentValues> | |
<dependentValues>PATCH</dependentValues> | |
<dependentValues>PUT</dependentValues> | |
<propertyName>HTTP Method</propertyName> | |
</dependencies> | |
<name>Content-Encoding</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Content-Type</key> | |
<value> | |
<dependencies> | |
<dependentValues>POST</dependentValues> | |
<dependentValues>PATCH</dependentValues> | |
<dependentValues>PUT</dependentValues> | |
<propertyName>HTTP Method</propertyName> | |
</dependencies> | |
<name>Content-Type</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Include Date Header</key> | |
<value> | |
<name>Include Date Header</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Attributes to Send</key> | |
<value> | |
<name>Attributes to Send</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Useragent</key> | |
<value> | |
<name>Useragent</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Put Response Body In Attribute</key> | |
<value> | |
<name>Put Response Body In Attribute</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Max Length To Put In Attribute</key> | |
<value> | |
<dependencies> | |
<propertyName>Put Response Body In Attribute</propertyName> | |
</dependencies> | |
<name>Max Length To Put In Attribute</name> | |
</value> | |
</entry> | |
<entry> | |
<key>ignore-response-content</key> | |
<value> | |
<name>ignore-response-content</name> | |
</value> | |
</entry> | |
<entry> | |
<key>use-etag</key> | |
<value> | |
<name>use-etag</name> | |
</value> | |
</entry> | |
<entry> | |
<key>etag-max-cache-size</key> | |
<value> | |
<dependencies> | |
<dependentValues>true</dependentValues> | |
<propertyName>use-etag</propertyName> | |
</dependencies> | |
<name>etag-max-cache-size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>cookie-strategy</key> | |
<value> | |
<name>cookie-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Always Output Response</key> | |
<value> | |
<name>Always Output Response</name> | |
</value> | |
</entry> | |
<entry> | |
<key>flow-file-naming-strategy</key> | |
<value> | |
<name>flow-file-naming-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Add Response Headers to Request</key> | |
<value> | |
<name>Add Response Headers to Request</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Follow Redirects</key> | |
<value> | |
<name>Follow Redirects</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<maxBackoffPeriod>10 mins</maxBackoffPeriod> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>HTTP Method</key> | |
<value>GET</value> | |
</entry> | |
<entry> | |
<key>Remote URL</key> | |
<value>https://www.pegelonline.wsv.de/webservices/rest-api/v2/stations/${station_uuid}/W/measurements.json?start=P30D</value> | |
</entry> | |
<entry> | |
<key>disable-http2</key> | |
<value>False</value> | |
</entry> | |
<entry> | |
<key>SSL Context Service</key> | |
</entry> | |
<entry> | |
<key>Connection Timeout</key> | |
<value>5 secs</value> | |
</entry> | |
<entry> | |
<key>Read Timeout</key> | |
<value>15 secs</value> | |
</entry> | |
<entry> | |
<key>Socket Write Timeout</key> | |
<value>15 secs</value> | |
</entry> | |
<entry> | |
<key>idle-timeout</key> | |
<value>5 mins</value> | |
</entry> | |
<entry> | |
<key>max-idle-connections</key> | |
<value>5</value> | |
</entry> | |
<entry> | |
<key>proxy-configuration-service</key> | |
</entry> | |
<entry> | |
<key>Proxy Host</key> | |
</entry> | |
<entry> | |
<key>Proxy Port</key> | |
</entry> | |
<entry> | |
<key>Proxy Type</key> | |
<value>http</value> | |
</entry> | |
<entry> | |
<key>invokehttp-proxy-user</key> | |
</entry> | |
<entry> | |
<key>invokehttp-proxy-password</key> | |
</entry> | |
<entry> | |
<key>oauth2-access-token-provider</key> | |
</entry> | |
<entry> | |
<key>Basic Authentication Username</key> | |
</entry> | |
<entry> | |
<key>Basic Authentication Password</key> | |
</entry> | |
<entry> | |
<key>Digest Authentication</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Penalize on "No Retry"</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>send-message-body</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>form-body-form-name</key> | |
</entry> | |
<entry> | |
<key>set-form-filename</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>Use Chunked Encoding</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Content-Encoding</key> | |
<value>DISABLED</value> | |
</entry> | |
<entry> | |
<key>Content-Type</key> | |
<value>${mime.type}</value> | |
</entry> | |
<entry> | |
<key>Include Date Header</key> | |
<value>True</value> | |
</entry> | |
<entry> | |
<key>Attributes to Send</key> | |
</entry> | |
<entry> | |
<key>Useragent</key> | |
</entry> | |
<entry> | |
<key>Put Response Body In Attribute</key> | |
</entry> | |
<entry> | |
<key>Max Length To Put In Attribute</key> | |
<value>256</value> | |
</entry> | |
<entry> | |
<key>ignore-response-content</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>use-etag</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>etag-max-cache-size</key> | |
<value>10MB</value> | |
</entry> | |
<entry> | |
<key>cookie-strategy</key> | |
<value>DISABLED</value> | |
</entry> | |
<entry> | |
<key>Always Output Response</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>flow-file-naming-strategy</key> | |
<value>RANDOM</value> | |
</entry> | |
<entry> | |
<key>Add Response Headers to Request</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Follow Redirects</key> | |
<value>True</value> | |
</entry> | |
</properties> | |
<retryCount>10</retryCount> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>Get 30 days historic data</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>Failure</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>No Retry</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>Original</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>Response</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>Retry</name> | |
<retry>false</retry> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.InvokeHTTP</type> | |
</processors> | |
<processors> | |
<id>4c829980-49fa-3a45-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<position> | |
<x>384.0</x> | |
<y>68.0</y> | |
</position> | |
<versionedComponentId>4c829980-49fa-3a45-a8c8-3712d57731b2</versionedComponentId> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.27.0</version> | |
</bundle> | |
<config> | |
<backoffMechanism>PENALIZE_FLOWFILE</backoffMechanism> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>HTTP Method</key> | |
<value> | |
<name>HTTP Method</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Remote URL</key> | |
<value> | |
<name>Remote URL</name> | |
</value> | |
</entry> | |
<entry> | |
<key>disable-http2</key> | |
<value> | |
<name>disable-http2</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>Connection Timeout</key> | |
<value> | |
<name>Connection Timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Read Timeout</key> | |
<value> | |
<name>Read Timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Socket Write Timeout</key> | |
<value> | |
<name>Socket Write Timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>idle-timeout</key> | |
<value> | |
<name>idle-timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max-idle-connections</key> | |
<value> | |
<name>max-idle-connections</name> | |
</value> | |
</entry> | |
<entry> | |
<key>proxy-configuration-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.proxy.ProxyConfigurationService</identifiesControllerService> | |
<name>proxy-configuration-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Proxy Host</key> | |
<value> | |
<name>Proxy Host</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Proxy Port</key> | |
<value> | |
<dependencies> | |
<propertyName>Proxy Host</propertyName> | |
</dependencies> | |
<name>Proxy Port</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Proxy Type</key> | |
<value> | |
<dependencies> | |
<propertyName>Proxy Host</propertyName> | |
</dependencies> | |
<name>Proxy Type</name> | |
</value> | |
</entry> | |
<entry> | |
<key>invokehttp-proxy-user</key> | |
<value> | |
<dependencies> | |
<propertyName>Proxy Host</propertyName> | |
</dependencies> | |
<name>invokehttp-proxy-user</name> | |
</value> | |
</entry> | |
<entry> | |
<key>invokehttp-proxy-password</key> | |
<value> | |
<dependencies> | |
<propertyName>Proxy Host</propertyName> | |
</dependencies> | |
<name>invokehttp-proxy-password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>oauth2-access-token-provider</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.oauth2.OAuth2AccessTokenProvider</identifiesControllerService> | |
<name>oauth2-access-token-provider</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Basic Authentication Username</key> | |
<value> | |
<name>Basic Authentication Username</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Basic Authentication Password</key> | |
<value> | |
<name>Basic Authentication Password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Digest Authentication</key> | |
<value> | |
<dependencies> | |
<propertyName>Basic Authentication Username</propertyName> | |
</dependencies> | |
<name>Digest Authentication</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Penalize on "No Retry"</key> | |
<value> | |
<name>Penalize on "No Retry"</name> | |
</value> | |
</entry> | |
<entry> | |
<key>send-message-body</key> | |
<value> | |
<dependencies> | |
<dependentValues>POST</dependentValues> | |
<dependentValues>PATCH</dependentValues> | |
<dependentValues>PUT</dependentValues> | |
<propertyName>HTTP Method</propertyName> | |
</dependencies> | |
<name>send-message-body</name> | |
</value> | |
</entry> | |
<entry> | |
<key>form-body-form-name</key> | |
<value> | |
<dependencies> | |
<dependentValues>true</dependentValues> | |
<propertyName>send-message-body</propertyName> | |
</dependencies> | |
<name>form-body-form-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>set-form-filename</key> | |
<value> | |
<dependencies> | |
<propertyName>form-body-form-name</propertyName> | |
</dependencies> | |
<name>set-form-filename</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Use Chunked Encoding</key> | |
<value> | |
<dependencies> | |
<dependentValues>POST</dependentValues> | |
<dependentValues>PATCH</dependentValues> | |
<dependentValues>PUT</dependentValues> | |
<propertyName>HTTP Method</propertyName> | |
</dependencies> | |
<name>Use Chunked Encoding</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Content-Encoding</key> | |
<value> | |
<dependencies> | |
<dependentValues>POST</dependentValues> | |
<dependentValues>PATCH</dependentValues> | |
<dependentValues>PUT</dependentValues> | |
<propertyName>HTTP Method</propertyName> | |
</dependencies> | |
<name>Content-Encoding</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Content-Type</key> | |
<value> | |
<dependencies> | |
<dependentValues>POST</dependentValues> | |
<dependentValues>PATCH</dependentValues> | |
<dependentValues>PUT</dependentValues> | |
<propertyName>HTTP Method</propertyName> | |
</dependencies> | |
<name>Content-Type</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Include Date Header</key> | |
<value> | |
<name>Include Date Header</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Attributes to Send</key> | |
<value> | |
<name>Attributes to Send</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Useragent</key> | |
<value> | |
<name>Useragent</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Put Response Body In Attribute</key> | |
<value> | |
<name>Put Response Body In Attribute</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Max Length To Put In Attribute</key> | |
<value> | |
<dependencies> | |
<propertyName>Put Response Body In Attribute</propertyName> | |
</dependencies> | |
<name>Max Length To Put In Attribute</name> | |
</value> | |
</entry> | |
<entry> | |
<key>ignore-response-content</key> | |
<value> | |
<name>ignore-response-content</name> | |
</value> | |
</entry> | |
<entry> | |
<key>use-etag</key> | |
<value> | |
<name>use-etag</name> | |
</value> | |
</entry> | |
<entry> | |
<key>etag-max-cache-size</key> | |
<value> | |
<dependencies> | |
<dependentValues>true</dependentValues> | |
<propertyName>use-etag</propertyName> | |
</dependencies> | |
<name>etag-max-cache-size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>cookie-strategy</key> | |
<value> | |
<name>cookie-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Always Output Response</key> | |
<value> | |
<name>Always Output Response</name> | |
</value> | |
</entry> | |
<entry> | |
<key>flow-file-naming-strategy</key> | |
<value> | |
<name>flow-file-naming-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Add Response Headers to Request</key> | |
<value> | |
<name>Add Response Headers to Request</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Follow Redirects</key> | |
<value> | |
<name>Follow Redirects</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>PRIMARY</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<maxBackoffPeriod>10 mins</maxBackoffPeriod> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>HTTP Method</key> | |
<value>GET</value> | |
</entry> | |
<entry> | |
<key>Remote URL</key> | |
<value>https://www.pegelonline.wsv.de/webservices/rest-api/v2/stations.json</value> | |
</entry> | |
<entry> | |
<key>disable-http2</key> | |
<value>False</value> | |
</entry> | |
<entry> | |
<key>SSL Context Service</key> | |
</entry> | |
<entry> | |
<key>Connection Timeout</key> | |
<value>5 secs</value> | |
</entry> | |
<entry> | |
<key>Read Timeout</key> | |
<value>15 secs</value> | |
</entry> | |
<entry> | |
<key>Socket Write Timeout</key> | |
<value>15 secs</value> | |
</entry> | |
<entry> | |
<key>idle-timeout</key> | |
<value>5 mins</value> | |
</entry> | |
<entry> | |
<key>max-idle-connections</key> | |
<value>5</value> | |
</entry> | |
<entry> | |
<key>proxy-configuration-service</key> | |
</entry> | |
<entry> | |
<key>Proxy Host</key> | |
</entry> | |
<entry> | |
<key>Proxy Port</key> | |
</entry> | |
<entry> | |
<key>Proxy Type</key> | |
<value>http</value> | |
</entry> | |
<entry> | |
<key>invokehttp-proxy-user</key> | |
</entry> | |
<entry> | |
<key>invokehttp-proxy-password</key> | |
</entry> | |
<entry> | |
<key>oauth2-access-token-provider</key> | |
</entry> | |
<entry> | |
<key>Basic Authentication Username</key> | |
</entry> | |
<entry> | |
<key>Basic Authentication Password</key> | |
</entry> | |
<entry> | |
<key>Digest Authentication</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Penalize on "No Retry"</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>send-message-body</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>form-body-form-name</key> | |
</entry> | |
<entry> | |
<key>set-form-filename</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>Use Chunked Encoding</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Content-Encoding</key> | |
<value>DISABLED</value> | |
</entry> | |
<entry> | |
<key>Content-Type</key> | |
<value>${mime.type}</value> | |
</entry> | |
<entry> | |
<key>Include Date Header</key> | |
<value>True</value> | |
</entry> | |
<entry> | |
<key>Attributes to Send</key> | |
</entry> | |
<entry> | |
<key>Useragent</key> | |
</entry> | |
<entry> | |
<key>Put Response Body In Attribute</key> | |
</entry> | |
<entry> | |
<key>Max Length To Put In Attribute</key> | |
<value>256</value> | |
</entry> | |
<entry> | |
<key>ignore-response-content</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>use-etag</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>etag-max-cache-size</key> | |
<value>10MB</value> | |
</entry> | |
<entry> | |
<key>cookie-strategy</key> | |
<value>DISABLED</value> | |
</entry> | |
<entry> | |
<key>Always Output Response</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>flow-file-naming-strategy</key> | |
<value>RANDOM</value> | |
</entry> | |
<entry> | |
<key>Add Response Headers to Request</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Follow Redirects</key> | |
<value>True</value> | |
</entry> | |
</properties> | |
<retryCount>10</retryCount> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>365000 days</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>Get station list</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>Failure</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>No Retry</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>Original</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>Response</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>Retry</name> | |
<retry>false</retry> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.InvokeHTTP</type> | |
</processors> | |
<processors> | |
<id>5be559ad-e255-3181-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<position> | |
<x>1142.0</x> | |
<y>336.0</y> | |
</position> | |
<versionedComponentId>5be559ad-e255-3181-a892-bfafd5800193</versionedComponentId> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.27.0</version> | |
</bundle> | |
<config> | |
<backoffMechanism>PENALIZE_FLOWFILE</backoffMechanism> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>Record Reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>Record Reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Record Writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>Record Writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Records Per Split</key> | |
<value> | |
<name>Records Per Split</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<maxBackoffPeriod>10 mins</maxBackoffPeriod> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>Record Reader</key> | |
<value>2b513981-28e9-344b-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>Record Writer</key> | |
<value>2b81a8e5-eec1-3f15-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>Records Per Split</key> | |
<value>1</value> | |
</entry> | |
</properties> | |
<retryCount>10</retryCount> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>SplitRecord</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>original</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>splits</name> | |
<retry>false</retry> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.SplitRecord</type> | |
</processors> | |
<processors> | |
<id>841af892-1afb-38e1-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<position> | |
<x>766.0</x> | |
<y>336.0</y> | |
</position> | |
<versionedComponentId>841af892-1afb-38e1-8df1-285672c8cce2</versionedComponentId> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.27.0</version> | |
</bundle> | |
<config> | |
<backoffMechanism>PENALIZE_FLOWFILE</backoffMechanism> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>Record Reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>Record Reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Record Writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>Record Writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Records Per Split</key> | |
<value> | |
<name>Records Per Split</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<maxBackoffPeriod>10 mins</maxBackoffPeriod> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>Record Reader</key> | |
<value>2b513981-28e9-344b-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>Record Writer</key> | |
<value>2b81a8e5-eec1-3f15-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>Records Per Split</key> | |
<value>1</value> | |
</entry> | |
</properties> | |
<retryCount>10</retryCount> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>SplitRecord</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>original</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>splits</name> | |
<retry>false</retry> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.SplitRecord</type> | |
</processors> | |
<processors> | |
<id>90106fb6-2708-3a48-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<position> | |
<x>766.0</x> | |
<y>72.0</y> | |
</position> | |
<versionedComponentId>90106fb6-2708-3a48-86df-1019e55acdab</versionedComponentId> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.27.0</version> | |
</bundle> | |
<config> | |
<backoffMechanism>PENALIZE_FLOWFILE</backoffMechanism> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>HTTP Method</key> | |
<value> | |
<name>HTTP Method</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Remote URL</key> | |
<value> | |
<name>Remote URL</name> | |
</value> | |
</entry> | |
<entry> | |
<key>disable-http2</key> | |
<value> | |
<name>disable-http2</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>Connection Timeout</key> | |
<value> | |
<name>Connection Timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Read Timeout</key> | |
<value> | |
<name>Read Timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Socket Write Timeout</key> | |
<value> | |
<name>Socket Write Timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>idle-timeout</key> | |
<value> | |
<name>idle-timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max-idle-connections</key> | |
<value> | |
<name>max-idle-connections</name> | |
</value> | |
</entry> | |
<entry> | |
<key>proxy-configuration-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.proxy.ProxyConfigurationService</identifiesControllerService> | |
<name>proxy-configuration-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Proxy Host</key> | |
<value> | |
<name>Proxy Host</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Proxy Port</key> | |
<value> | |
<dependencies> | |
<propertyName>Proxy Host</propertyName> | |
</dependencies> | |
<name>Proxy Port</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Proxy Type</key> | |
<value> | |
<dependencies> | |
<propertyName>Proxy Host</propertyName> | |
</dependencies> | |
<name>Proxy Type</name> | |
</value> | |
</entry> | |
<entry> | |
<key>invokehttp-proxy-user</key> | |
<value> | |
<dependencies> | |
<propertyName>Proxy Host</propertyName> | |
</dependencies> | |
<name>invokehttp-proxy-user</name> | |
</value> | |
</entry> | |
<entry> | |
<key>invokehttp-proxy-password</key> | |
<value> | |
<dependencies> | |
<propertyName>Proxy Host</propertyName> | |
</dependencies> | |
<name>invokehttp-proxy-password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>oauth2-access-token-provider</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.oauth2.OAuth2AccessTokenProvider</identifiesControllerService> | |
<name>oauth2-access-token-provider</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Basic Authentication Username</key> | |
<value> | |
<name>Basic Authentication Username</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Basic Authentication Password</key> | |
<value> | |
<name>Basic Authentication Password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Digest Authentication</key> | |
<value> | |
<dependencies> | |
<propertyName>Basic Authentication Username</propertyName> | |
</dependencies> | |
<name>Digest Authentication</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Penalize on "No Retry"</key> | |
<value> | |
<name>Penalize on "No Retry"</name> | |
</value> | |
</entry> | |
<entry> | |
<key>send-message-body</key> | |
<value> | |
<dependencies> | |
<dependentValues>POST</dependentValues> | |
<dependentValues>PATCH</dependentValues> | |
<dependentValues>PUT</dependentValues> | |
<propertyName>HTTP Method</propertyName> | |
</dependencies> | |
<name>send-message-body</name> | |
</value> | |
</entry> | |
<entry> | |
<key>form-body-form-name</key> | |
<value> | |
<dependencies> | |
<dependentValues>true</dependentValues> | |
<propertyName>send-message-body</propertyName> | |
</dependencies> | |
<name>form-body-form-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>set-form-filename</key> | |
<value> | |
<dependencies> | |
<propertyName>form-body-form-name</propertyName> | |
</dependencies> | |
<name>set-form-filename</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Use Chunked Encoding</key> | |
<value> | |
<dependencies> | |
<dependentValues>POST</dependentValues> | |
<dependentValues>PATCH</dependentValues> | |
<dependentValues>PUT</dependentValues> | |
<propertyName>HTTP Method</propertyName> | |
</dependencies> | |
<name>Use Chunked Encoding</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Content-Encoding</key> | |
<value> | |
<dependencies> | |
<dependentValues>POST</dependentValues> | |
<dependentValues>PATCH</dependentValues> | |
<dependentValues>PUT</dependentValues> | |
<propertyName>HTTP Method</propertyName> | |
</dependencies> | |
<name>Content-Encoding</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Content-Type</key> | |
<value> | |
<dependencies> | |
<dependentValues>POST</dependentValues> | |
<dependentValues>PATCH</dependentValues> | |
<dependentValues>PUT</dependentValues> | |
<propertyName>HTTP Method</propertyName> | |
</dependencies> | |
<name>Content-Type</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Include Date Header</key> | |
<value> | |
<name>Include Date Header</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Attributes to Send</key> | |
<value> | |
<name>Attributes to Send</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Useragent</key> | |
<value> | |
<name>Useragent</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Put Response Body In Attribute</key> | |
<value> | |
<name>Put Response Body In Attribute</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Max Length To Put In Attribute</key> | |
<value> | |
<dependencies> | |
<propertyName>Put Response Body In Attribute</propertyName> | |
</dependencies> | |
<name>Max Length To Put In Attribute</name> | |
</value> | |
</entry> | |
<entry> | |
<key>ignore-response-content</key> | |
<value> | |
<name>ignore-response-content</name> | |
</value> | |
</entry> | |
<entry> | |
<key>use-etag</key> | |
<value> | |
<name>use-etag</name> | |
</value> | |
</entry> | |
<entry> | |
<key>etag-max-cache-size</key> | |
<value> | |
<dependencies> | |
<dependentValues>true</dependentValues> | |
<propertyName>use-etag</propertyName> | |
</dependencies> | |
<name>etag-max-cache-size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>cookie-strategy</key> | |
<value> | |
<name>cookie-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Always Output Response</key> | |
<value> | |
<name>Always Output Response</name> | |
</value> | |
</entry> | |
<entry> | |
<key>flow-file-naming-strategy</key> | |
<value> | |
<name>flow-file-naming-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Add Response Headers to Request</key> | |
<value> | |
<name>Add Response Headers to Request</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Follow Redirects</key> | |
<value> | |
<name>Follow Redirects</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>PRIMARY</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<maxBackoffPeriod>10 mins</maxBackoffPeriod> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>HTTP Method</key> | |
<value>GET</value> | |
</entry> | |
<entry> | |
<key>Remote URL</key> | |
<value>https://www.pegelonline.wsv.de/webservices/rest-api/v2/stations.json</value> | |
</entry> | |
<entry> | |
<key>disable-http2</key> | |
<value>False</value> | |
</entry> | |
<entry> | |
<key>SSL Context Service</key> | |
</entry> | |
<entry> | |
<key>Connection Timeout</key> | |
<value>5 secs</value> | |
</entry> | |
<entry> | |
<key>Read Timeout</key> | |
<value>15 secs</value> | |
</entry> | |
<entry> | |
<key>Socket Write Timeout</key> | |
<value>15 secs</value> | |
</entry> | |
<entry> | |
<key>idle-timeout</key> | |
<value>5 mins</value> | |
</entry> | |
<entry> | |
<key>max-idle-connections</key> | |
<value>5</value> | |
</entry> | |
<entry> | |
<key>proxy-configuration-service</key> | |
</entry> | |
<entry> | |
<key>Proxy Host</key> | |
</entry> | |
<entry> | |
<key>Proxy Port</key> | |
</entry> | |
<entry> | |
<key>Proxy Type</key> | |
<value>http</value> | |
</entry> | |
<entry> | |
<key>invokehttp-proxy-user</key> | |
</entry> | |
<entry> | |
<key>invokehttp-proxy-password</key> | |
</entry> | |
<entry> | |
<key>oauth2-access-token-provider</key> | |
</entry> | |
<entry> | |
<key>Basic Authentication Username</key> | |
</entry> | |
<entry> | |
<key>Basic Authentication Password</key> | |
</entry> | |
<entry> | |
<key>Digest Authentication</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Penalize on "No Retry"</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>send-message-body</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>form-body-form-name</key> | |
</entry> | |
<entry> | |
<key>set-form-filename</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>Use Chunked Encoding</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Content-Encoding</key> | |
<value>DISABLED</value> | |
</entry> | |
<entry> | |
<key>Content-Type</key> | |
<value>${mime.type}</value> | |
</entry> | |
<entry> | |
<key>Include Date Header</key> | |
<value>True</value> | |
</entry> | |
<entry> | |
<key>Attributes to Send</key> | |
</entry> | |
<entry> | |
<key>Useragent</key> | |
</entry> | |
<entry> | |
<key>Put Response Body In Attribute</key> | |
</entry> | |
<entry> | |
<key>Max Length To Put In Attribute</key> | |
<value>256</value> | |
</entry> | |
<entry> | |
<key>ignore-response-content</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>use-etag</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>etag-max-cache-size</key> | |
<value>10MB</value> | |
</entry> | |
<entry> | |
<key>cookie-strategy</key> | |
<value>DISABLED</value> | |
</entry> | |
<entry> | |
<key>Always Output Response</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>flow-file-naming-strategy</key> | |
<value>RANDOM</value> | |
</entry> | |
<entry> | |
<key>Add Response Headers to Request</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Follow Redirects</key> | |
<value>True</value> | |
</entry> | |
</properties> | |
<retryCount>10</retryCount> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>365000 days</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>Get station list</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>Failure</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>No Retry</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>Original</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>Response</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>Retry</name> | |
<retry>false</retry> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.InvokeHTTP</type> | |
</processors> | |
<processors> | |
<id>a9882099-7faa-316e-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<position> | |
<x>1142.0</x> | |
<y>1016.0</y> | |
</position> | |
<versionedComponentId>a9882099-7faa-316e-96db-323da0f2cb44</versionedComponentId> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.27.0</version> | |
</bundle> | |
<config> | |
<backoffMechanism>PENALIZE_FLOWFILE</backoffMechanism> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>jolt-transform</key> | |
<value> | |
<name>jolt-transform</name> | |
</value> | |
</entry> | |
<entry> | |
<key>jolt-custom-class</key> | |
<value> | |
<dependencies> | |
<dependentValues>jolt-transform-custom</dependentValues> | |
<propertyName>jolt-transform</propertyName> | |
</dependencies> | |
<name>jolt-custom-class</name> | |
</value> | |
</entry> | |
<entry> | |
<key>jolt-custom-modules</key> | |
<value> | |
<dependencies> | |
<dependentValues>jolt-transform-custom</dependentValues> | |
<propertyName>jolt-transform</propertyName> | |
</dependencies> | |
<name>jolt-custom-modules</name> | |
</value> | |
</entry> | |
<entry> | |
<key>jolt-spec</key> | |
<value> | |
<name>jolt-spec</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Transform Cache Size</key> | |
<value> | |
<name>Transform Cache Size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>pretty_print</key> | |
<value> | |
<name>pretty_print</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Max String Length</key> | |
<value> | |
<name>Max String Length</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<maxBackoffPeriod>10 mins</maxBackoffPeriod> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>jolt-transform</key> | |
<value>jolt-transform-chain</value> | |
</entry> | |
<entry> | |
<key>jolt-custom-class</key> | |
</entry> | |
<entry> | |
<key>jolt-custom-modules</key> | |
</entry> | |
<entry> | |
<key>jolt-spec</key> | |
<value>[ | |
{ | |
"operation": "default", | |
"spec": { | |
"*": { | |
"station_uuid": "${station_uuid}" | |
} | |
} | |
} | |
] | |
</value> | |
</entry> | |
<entry> | |
<key>Transform Cache Size</key> | |
<value>1</value> | |
</entry> | |
<entry> | |
<key>pretty_print</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Max String Length</key> | |
<value>20 MB</value> | |
</entry> | |
</properties> | |
<retryCount>10</retryCount> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>Add station_uuid</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
<retry>false</retry> | |
</relationships> | |
<state>RUNNING</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.JoltTransformJSON</type> | |
</processors> | |
<processors> | |
<id>b016c33d-7bc2-3a06-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<position> | |
<x>1142.0</x> | |
<y>552.0</y> | |
</position> | |
<versionedComponentId>b016c33d-7bc2-3a06-9867-ae062a3a9ea8</versionedComponentId> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.27.0</version> | |
</bundle> | |
<config> | |
<backoffMechanism>PENALIZE_FLOWFILE</backoffMechanism> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>Destination</key> | |
<value> | |
<name>Destination</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Return Type</key> | |
<value> | |
<name>Return Type</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Path Not Found Behavior</key> | |
<value> | |
<dependencies> | |
<dependentValues>flowfile-attribute</dependentValues> | |
<propertyName>Destination</propertyName> | |
</dependencies> | |
<name>Path Not Found Behavior</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Null Value Representation</key> | |
<value> | |
<name>Null Value Representation</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Max String Length</key> | |
<value> | |
<name>Max String Length</name> | |
</value> | |
</entry> | |
<entry> | |
<key>station_uuid</key> | |
<value> | |
<name>station_uuid</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<maxBackoffPeriod>10 mins</maxBackoffPeriod> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>Destination</key> | |
<value>flowfile-attribute</value> | |
</entry> | |
<entry> | |
<key>Return Type</key> | |
<value>auto-detect</value> | |
</entry> | |
<entry> | |
<key>Path Not Found Behavior</key> | |
<value>ignore</value> | |
</entry> | |
<entry> | |
<key>Null Value Representation</key> | |
<value>empty string</value> | |
</entry> | |
<entry> | |
<key>Max String Length</key> | |
<value>20 MB</value> | |
</entry> | |
<entry> | |
<key>station_uuid</key> | |
<value>$.uuid</value> | |
</entry> | |
</properties> | |
<retryCount>10</retryCount> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>Extract station_uuid</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>matched</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>unmatched</name> | |
<retry>false</retry> | |
</relationships> | |
<state>RUNNING</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.EvaluateJsonPath</type> | |
</processors> | |
<processors> | |
<id>cf8a985d-19b7-36ac-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<position> | |
<x>384.0</x> | |
<y>796.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-hadoop-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.27.0</version> | |
</bundle> | |
<config> | |
<backoffMechanism>PENALIZE_FLOWFILE</backoffMechanism> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>Hadoop Configuration Resources</key> | |
<value> | |
<name>Hadoop Configuration Resources</name> | |
</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.kerberos.KerberosCredentialsService</identifiesControllerService> | |
<name>kerberos-credentials-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>kerberos-user-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.kerberos.KerberosUserService</identifiesControllerService> | |
<name>kerberos-user-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Kerberos Principal</key> | |
<value> | |
<name>Kerberos Principal</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Kerberos Keytab</key> | |
<value> | |
<name>Kerberos Keytab</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Kerberos Password</key> | |
<value> | |
<name>Kerberos Password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Kerberos Relogin Period</key> | |
<value> | |
<name>Kerberos Relogin Period</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Additional Classpath Resources</key> | |
<value> | |
<name>Additional Classpath Resources</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Directory</key> | |
<value> | |
<name>Directory</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Conflict Resolution Strategy</key> | |
<value> | |
<name>Conflict Resolution Strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Append Mode</key> | |
<value> | |
<dependencies> | |
<dependentValues>append</dependentValues> | |
<propertyName>Conflict Resolution Strategy</propertyName> | |
</dependencies> | |
<name>Append Mode</name> | |
</value> | |
</entry> | |
<entry> | |
<key>writing-strategy</key> | |
<value> | |
<name>writing-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Block Size</key> | |
<value> | |
<name>Block Size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>IO Buffer Size</key> | |
<value> | |
<name>IO Buffer Size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Replication</key> | |
<value> | |
<name>Replication</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Permissions umask</key> | |
<value> | |
<name>Permissions umask</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Remote Owner</key> | |
<value> | |
<name>Remote Owner</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Remote Group</key> | |
<value> | |
<name>Remote Group</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Compression codec</key> | |
<value> | |
<name>Compression codec</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Ignore Locality</key> | |
<value> | |
<name>Ignore Locality</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<maxBackoffPeriod>10 mins</maxBackoffPeriod> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>Hadoop Configuration Resources</key> | |
<value>/stackable/config/hdfs/core-site.xml,/stackable/config/hdfs/hdfs-site.xml</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
<value>175d68ec-57f4-30c9-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>kerberos-user-service</key> | |
</entry> | |
<entry> | |
<key>Kerberos Principal</key> | |
</entry> | |
<entry> | |
<key>Kerberos Keytab</key> | |
</entry> | |
<entry> | |
<key>Kerberos Password</key> | |
</entry> | |
<entry> | |
<key>Kerberos Relogin Period</key> | |
<value>4 hours</value> | |
</entry> | |
<entry> | |
<key>Additional Classpath Resources</key> | |
</entry> | |
<entry> | |
<key>Directory</key> | |
<value>/staging/stations</value> | |
</entry> | |
<entry> | |
<key>Conflict Resolution Strategy</key> | |
<value>fail</value> | |
</entry> | |
<entry> | |
<key>Append Mode</key> | |
<value>DEFAULT</value> | |
</entry> | |
<entry> | |
<key>writing-strategy</key> | |
<value>writeAndRename</value> | |
</entry> | |
<entry> | |
<key>Block Size</key> | |
</entry> | |
<entry> | |
<key>IO Buffer Size</key> | |
</entry> | |
<entry> | |
<key>Replication</key> | |
</entry> | |
<entry> | |
<key>Permissions umask</key> | |
</entry> | |
<entry> | |
<key>Remote Owner</key> | |
</entry> | |
<entry> | |
<key>Remote Group</key> | |
</entry> | |
<entry> | |
<key>Compression codec</key> | |
<value>NONE</value> | |
</entry> | |
<entry> | |
<key>Ignore Locality</key> | |
<value>false</value> | |
</entry> | |
</properties> | |
<retryCount>10</retryCount> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>PutHDFS</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>success</name> | |
<retry>false</retry> | |
</relationships> | |
<state>RUNNING</state> | |
<style/> | |
<type>org.apache.nifi.processors.hadoop.PutHDFS</type> | |
</processors> | |
<processors> | |
<id>d25b4d75-7425-3372-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<position> | |
<x>766.0</x> | |
<y>552.0</y> | |
</position> | |
<versionedComponentId>d25b4d75-7425-3372-b3fa-b7c5930a9afd</versionedComponentId> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.27.0</version> | |
</bundle> | |
<config> | |
<backoffMechanism>PENALIZE_FLOWFILE</backoffMechanism> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>Destination</key> | |
<value> | |
<name>Destination</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Return Type</key> | |
<value> | |
<name>Return Type</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Path Not Found Behavior</key> | |
<value> | |
<dependencies> | |
<dependentValues>flowfile-attribute</dependentValues> | |
<propertyName>Destination</propertyName> | |
</dependencies> | |
<name>Path Not Found Behavior</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Null Value Representation</key> | |
<value> | |
<name>Null Value Representation</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Max String Length</key> | |
<value> | |
<name>Max String Length</name> | |
</value> | |
</entry> | |
<entry> | |
<key>station_uuid</key> | |
<value> | |
<name>station_uuid</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<maxBackoffPeriod>10 mins</maxBackoffPeriod> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>Destination</key> | |
<value>flowfile-attribute</value> | |
</entry> | |
<entry> | |
<key>Return Type</key> | |
<value>auto-detect</value> | |
</entry> | |
<entry> | |
<key>Path Not Found Behavior</key> | |
<value>ignore</value> | |
</entry> | |
<entry> | |
<key>Null Value Representation</key> | |
<value>empty string</value> | |
</entry> | |
<entry> | |
<key>Max String Length</key> | |
<value>20 MB</value> | |
</entry> | |
<entry> | |
<key>station_uuid</key> | |
<value>$.uuid</value> | |
</entry> | |
</properties> | |
<retryCount>10</retryCount> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>Extract station_uuid</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>matched</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>unmatched</name> | |
<retry>false</retry> | |
</relationships> | |
<state>STOPPED</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.EvaluateJsonPath</type> | |
</processors> | |
<processors> | |
<id>d72bdef3-afb2-3243-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<position> | |
<x>968.0</x> | |
<y>1372.0</y> | |
</position> | |
<versionedComponentId>d72bdef3-afb2-3243-bd45-85fd5325b5e0</versionedComponentId> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.27.0</version> | |
</bundle> | |
<config> | |
<backoffMechanism>PENALIZE_FLOWFILE</backoffMechanism> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>record-reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>record-reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>record-writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>merge-strategy</key> | |
<value> | |
<name>merge-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>correlation-attribute-name</key> | |
<value> | |
<name>correlation-attribute-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Attribute Strategy</key> | |
<value> | |
<name>Attribute Strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>min-records</key> | |
<value> | |
<name>min-records</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max-records</key> | |
<value> | |
<name>max-records</name> | |
</value> | |
</entry> | |
<entry> | |
<key>min-bin-size</key> | |
<value> | |
<name>min-bin-size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max-bin-size</key> | |
<value> | |
<name>max-bin-size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max-bin-age</key> | |
<value> | |
<name>max-bin-age</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max.bin.count</key> | |
<value> | |
<name>max.bin.count</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<maxBackoffPeriod>10 mins</maxBackoffPeriod> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>record-reader</key> | |
<value>2b513981-28e9-344b-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value>7d161aec-a83d-3493-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>merge-strategy</key> | |
<value>Bin-Packing Algorithm</value> | |
</entry> | |
<entry> | |
<key>correlation-attribute-name</key> | |
</entry> | |
<entry> | |
<key>Attribute Strategy</key> | |
<value>Keep Only Common Attributes</value> | |
</entry> | |
<entry> | |
<key>min-records</key> | |
<value>1</value> | |
</entry> | |
<entry> | |
<key>max-records</key> | |
<value>100000000</value> | |
</entry> | |
<entry> | |
<key>min-bin-size</key> | |
<value>32 MB</value> | |
</entry> | |
<entry> | |
<key>max-bin-size</key> | |
<value>64MB</value> | |
</entry> | |
<entry> | |
<key>max-bin-age</key> | |
<value>1 minutes</value> | |
</entry> | |
<entry> | |
<key>max.bin.count</key> | |
<value>10</value> | |
</entry> | |
</properties> | |
<retryCount>10</retryCount> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>MergeRecord</name> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>failure</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>merged</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>original</name> | |
<retry>false</retry> | |
</relationships> | |
<state>RUNNING</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.MergeRecord</type> | |
</processors> | |
<processors> | |
<id>dcc17c80-7492-3baf-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<position> | |
<x>1142.0</x> | |
<y>792.0</y> | |
</position> | |
<versionedComponentId>dcc17c80-7492-3baf-b512-7c7836a5f309</versionedComponentId> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.27.0</version> | |
</bundle> | |
<config> | |
<backoffMechanism>PENALIZE_FLOWFILE</backoffMechanism> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>HTTP Method</key> | |
<value> | |
<name>HTTP Method</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Remote URL</key> | |
<value> | |
<name>Remote URL</name> | |
</value> | |
</entry> | |
<entry> | |
<key>disable-http2</key> | |
<value> | |
<name>disable-http2</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>Connection Timeout</key> | |
<value> | |
<name>Connection Timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Read Timeout</key> | |
<value> | |
<name>Read Timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Socket Write Timeout</key> | |
<value> | |
<name>Socket Write Timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>idle-timeout</key> | |
<value> | |
<name>idle-timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max-idle-connections</key> | |
<value> | |
<name>max-idle-connections</name> | |
</value> | |
</entry> | |
<entry> | |
<key>proxy-configuration-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.proxy.ProxyConfigurationService</identifiesControllerService> | |
<name>proxy-configuration-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Proxy Host</key> | |
<value> | |
<name>Proxy Host</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Proxy Port</key> | |
<value> | |
<dependencies> | |
<propertyName>Proxy Host</propertyName> | |
</dependencies> | |
<name>Proxy Port</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Proxy Type</key> | |
<value> | |
<dependencies> | |
<propertyName>Proxy Host</propertyName> | |
</dependencies> | |
<name>Proxy Type</name> | |
</value> | |
</entry> | |
<entry> | |
<key>invokehttp-proxy-user</key> | |
<value> | |
<dependencies> | |
<propertyName>Proxy Host</propertyName> | |
</dependencies> | |
<name>invokehttp-proxy-user</name> | |
</value> | |
</entry> | |
<entry> | |
<key>invokehttp-proxy-password</key> | |
<value> | |
<dependencies> | |
<propertyName>Proxy Host</propertyName> | |
</dependencies> | |
<name>invokehttp-proxy-password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>oauth2-access-token-provider</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.oauth2.OAuth2AccessTokenProvider</identifiesControllerService> | |
<name>oauth2-access-token-provider</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Basic Authentication Username</key> | |
<value> | |
<name>Basic Authentication Username</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Basic Authentication Password</key> | |
<value> | |
<name>Basic Authentication Password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Digest Authentication</key> | |
<value> | |
<dependencies> | |
<propertyName>Basic Authentication Username</propertyName> | |
</dependencies> | |
<name>Digest Authentication</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Penalize on "No Retry"</key> | |
<value> | |
<name>Penalize on "No Retry"</name> | |
</value> | |
</entry> | |
<entry> | |
<key>send-message-body</key> | |
<value> | |
<dependencies> | |
<dependentValues>POST</dependentValues> | |
<dependentValues>PATCH</dependentValues> | |
<dependentValues>PUT</dependentValues> | |
<propertyName>HTTP Method</propertyName> | |
</dependencies> | |
<name>send-message-body</name> | |
</value> | |
</entry> | |
<entry> | |
<key>form-body-form-name</key> | |
<value> | |
<dependencies> | |
<dependentValues>true</dependentValues> | |
<propertyName>send-message-body</propertyName> | |
</dependencies> | |
<name>form-body-form-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>set-form-filename</key> | |
<value> | |
<dependencies> | |
<propertyName>form-body-form-name</propertyName> | |
</dependencies> | |
<name>set-form-filename</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Use Chunked Encoding</key> | |
<value> | |
<dependencies> | |
<dependentValues>POST</dependentValues> | |
<dependentValues>PATCH</dependentValues> | |
<dependentValues>PUT</dependentValues> | |
<propertyName>HTTP Method</propertyName> | |
</dependencies> | |
<name>Use Chunked Encoding</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Content-Encoding</key> | |
<value> | |
<dependencies> | |
<dependentValues>POST</dependentValues> | |
<dependentValues>PATCH</dependentValues> | |
<dependentValues>PUT</dependentValues> | |
<propertyName>HTTP Method</propertyName> | |
</dependencies> | |
<name>Content-Encoding</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Content-Type</key> | |
<value> | |
<dependencies> | |
<dependentValues>POST</dependentValues> | |
<dependentValues>PATCH</dependentValues> | |
<dependentValues>PUT</dependentValues> | |
<propertyName>HTTP Method</propertyName> | |
</dependencies> | |
<name>Content-Type</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Include Date Header</key> | |
<value> | |
<name>Include Date Header</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Attributes to Send</key> | |
<value> | |
<name>Attributes to Send</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Useragent</key> | |
<value> | |
<name>Useragent</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Put Response Body In Attribute</key> | |
<value> | |
<name>Put Response Body In Attribute</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Max Length To Put In Attribute</key> | |
<value> | |
<dependencies> | |
<propertyName>Put Response Body In Attribute</propertyName> | |
</dependencies> | |
<name>Max Length To Put In Attribute</name> | |
</value> | |
</entry> | |
<entry> | |
<key>ignore-response-content</key> | |
<value> | |
<name>ignore-response-content</name> | |
</value> | |
</entry> | |
<entry> | |
<key>use-etag</key> | |
<value> | |
<name>use-etag</name> | |
</value> | |
</entry> | |
<entry> | |
<key>etag-max-cache-size</key> | |
<value> | |
<dependencies> | |
<dependentValues>true</dependentValues> | |
<propertyName>use-etag</propertyName> | |
</dependencies> | |
<name>etag-max-cache-size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>cookie-strategy</key> | |
<value> | |
<name>cookie-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Always Output Response</key> | |
<value> | |
<name>Always Output Response</name> | |
</value> | |
</entry> | |
<entry> | |
<key>flow-file-naming-strategy</key> | |
<value> | |
<name>flow-file-naming-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Add Response Headers to Request</key> | |
<value> | |
<name>Add Response Headers to Request</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Follow Redirects</key> | |
<value> | |
<name>Follow Redirects</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<maxBackoffPeriod>10 mins</maxBackoffPeriod> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>HTTP Method</key> | |
<value>GET</value> | |
</entry> | |
<entry> | |
<key>Remote URL</key> | |
<value>https://www.pegelonline.wsv.de/webservices/rest-api/v2/stations/${station_uuid}/W/measurements.json?start=PT30M</value> | |
</entry> | |
<entry> | |
<key>disable-http2</key> | |
<value>False</value> | |
</entry> | |
<entry> | |
<key>SSL Context Service</key> | |
</entry> | |
<entry> | |
<key>Connection Timeout</key> | |
<value>5 secs</value> | |
</entry> | |
<entry> | |
<key>Read Timeout</key> | |
<value>15 secs</value> | |
</entry> | |
<entry> | |
<key>Socket Write Timeout</key> | |
<value>15 secs</value> | |
</entry> | |
<entry> | |
<key>idle-timeout</key> | |
<value>5 mins</value> | |
</entry> | |
<entry> | |
<key>max-idle-connections</key> | |
<value>5</value> | |
</entry> | |
<entry> | |
<key>proxy-configuration-service</key> | |
</entry> | |
<entry> | |
<key>Proxy Host</key> | |
</entry> | |
<entry> | |
<key>Proxy Port</key> | |
</entry> | |
<entry> | |
<key>Proxy Type</key> | |
<value>http</value> | |
</entry> | |
<entry> | |
<key>invokehttp-proxy-user</key> | |
</entry> | |
<entry> | |
<key>invokehttp-proxy-password</key> | |
</entry> | |
<entry> | |
<key>oauth2-access-token-provider</key> | |
</entry> | |
<entry> | |
<key>Basic Authentication Username</key> | |
</entry> | |
<entry> | |
<key>Basic Authentication Password</key> | |
</entry> | |
<entry> | |
<key>Digest Authentication</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Penalize on "No Retry"</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>send-message-body</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>form-body-form-name</key> | |
</entry> | |
<entry> | |
<key>set-form-filename</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>Use Chunked Encoding</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Content-Encoding</key> | |
<value>DISABLED</value> | |
</entry> | |
<entry> | |
<key>Content-Type</key> | |
<value>${mime.type}</value> | |
</entry> | |
<entry> | |
<key>Include Date Header</key> | |
<value>True</value> | |
</entry> | |
<entry> | |
<key>Attributes to Send</key> | |
</entry> | |
<entry> | |
<key>Useragent</key> | |
</entry> | |
<entry> | |
<key>Put Response Body In Attribute</key> | |
</entry> | |
<entry> | |
<key>Max Length To Put In Attribute</key> | |
<value>256</value> | |
</entry> | |
<entry> | |
<key>ignore-response-content</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>use-etag</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>etag-max-cache-size</key> | |
<value>10MB</value> | |
</entry> | |
<entry> | |
<key>cookie-strategy</key> | |
<value>DISABLED</value> | |
</entry> | |
<entry> | |
<key>Always Output Response</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>flow-file-naming-strategy</key> | |
<value>RANDOM</value> | |
</entry> | |
<entry> | |
<key>Add Response Headers to Request</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Follow Redirects</key> | |
<value>True</value> | |
</entry> | |
</properties> | |
<retryCount>10</retryCount> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>1 s</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>Get 30 minutes of historic data</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>Failure</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>No Retry</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>Original</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>Response</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>Retry</name> | |
<retry>false</retry> | |
</relationships> | |
<state>RUNNING</state> | |
<style/> | |
<type>org.apache.nifi.processors.standard.InvokeHTTP</type> | |
</processors> | |
<processors> | |
<id>e3541e25-c5a1-3ba7-0000-000000000000</id> | |
<parentGroupId>8f337141-9a3e-3b48-0000-000000000000</parentGroupId> | |
<position> | |
<x>968.0</x> | |
<y>1580.0</y> | |
</position> | |
<versionedComponentId>e3541e25-c5a1-3ba7-b6ec-f81b6961b249</versionedComponentId> | |
<bundle> | |
<artifact>nifi-hadoop-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.27.0</version> | |
</bundle> | |
<config> | |
<backoffMechanism>PENALIZE_FLOWFILE</backoffMechanism> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>Hadoop Configuration Resources</key> | |
<value> | |
<name>Hadoop Configuration Resources</name> | |
</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.kerberos.KerberosCredentialsService</identifiesControllerService> | |
<name>kerberos-credentials-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>kerberos-user-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.kerberos.KerberosUserService</identifiesControllerService> | |
<name>kerberos-user-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Kerberos Principal</key> | |
<value> | |
<name>Kerberos Principal</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Kerberos Keytab</key> | |
<value> | |
<name>Kerberos Keytab</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Kerberos Password</key> | |
<value> | |
<name>Kerberos Password</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Kerberos Relogin Period</key> | |
<value> | |
<name>Kerberos Relogin Period</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Additional Classpath Resources</key> | |
<value> | |
<name>Additional Classpath Resources</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Directory</key> | |
<value> | |
<name>Directory</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Conflict Resolution Strategy</key> | |
<value> | |
<name>Conflict Resolution Strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Append Mode</key> | |
<value> | |
<dependencies> | |
<dependentValues>append</dependentValues> | |
<propertyName>Conflict Resolution Strategy</propertyName> | |
</dependencies> | |
<name>Append Mode</name> | |
</value> | |
</entry> | |
<entry> | |
<key>writing-strategy</key> | |
<value> | |
<name>writing-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Block Size</key> | |
<value> | |
<name>Block Size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>IO Buffer Size</key> | |
<value> | |
<name>IO Buffer Size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Replication</key> | |
<value> | |
<name>Replication</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Permissions umask</key> | |
<value> | |
<name>Permissions umask</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Remote Owner</key> | |
<value> | |
<name>Remote Owner</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Remote Group</key> | |
<value> | |
<name>Remote Group</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Compression codec</key> | |
<value> | |
<name>Compression codec</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Ignore Locality</key> | |
<value> | |
<name>Ignore Locality</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<maxBackoffPeriod>10 mins</maxBackoffPeriod> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>Hadoop Configuration Resources</key> | |
<value>/stackable/config/hdfs/core-site.xml,/stackable/config/hdfs/hdfs-site.xml</value> | |
</entry> | |
<entry> | |
<key>kerberos-credentials-service</key> | |
<value>175d68ec-57f4-30c9-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>kerberos-user-service</key> | |
</entry> | |
<entry> | |
<key>Kerberos Principal</key> | |
</entry> | |
<entry> | |
<key>Kerberos Keytab</key> | |
</entry> | |
<entry> | |
<key>Kerberos Password</key> | |
</entry> | |
<entry> | |
<key>Kerberos Relogin Period</key> | |
<value>4 hours</value> | |
</entry> | |
<entry> | |
<key>Additional Classpath Resources</key> | |
</entry> | |
<entry> | |
<key>Directory</key> | |
<value>/staging/measurements</value> | |
</entry> | |
<entry> | |
<key>Conflict Resolution Strategy</key> | |
<value>fail</value> | |
</entry> | |
<entry> | |
<key>Append Mode</key> | |
<value>DEFAULT</value> | |
</entry> | |
<entry> | |
<key>writing-strategy</key> | |
<value>writeAndRename</value> | |
</entry> | |
<entry> | |
<key>Block Size</key> | |
</entry> | |
<entry> | |
<key>IO Buffer Size</key> | |
</entry> | |
<entry> | |
<key>Replication</key> | |
</entry> | |
<entry> | |
<key>Permissions umask</key> | |
</entry> | |
<entry> | |
<key>Remote Owner</key> | |
</entry> | |
<entry> | |
<key>Remote Group</key> | |
</entry> | |
<entry> | |
<key>Compression codec</key> | |
<value>NONE</value> | |
</entry> | |
<entry> | |
<key>Ignore Locality</key> | |
<value>false</value> | |
</entry> | |
</properties> | |
<retryCount>10</retryCount> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<executionNodeRestricted>false</executionNodeRestricted> | |
<name>PutHDFS</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>failure</name> | |
<retry>false</retry> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>success</name> | |
<retry>false</retry> | |
</relationships> | |
<state>RUNNING</state> | |
<style/> | |
<type>org.apache.nifi.processors.hadoop.PutHDFS</type> | |
</processors> | |
</snippet> | |
<timestamp>09/02/2024 20:23:43 GMT</timestamp> | |
</template> |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment