FetchDistributedMapCache 2025.5.31.15¶
Pacote¶
org.apache.nifi | nifi-standard-nar
Descrição¶
Calcula a(s) chave(s) do cache a partir dos atributos do FlowFile, para cada FlowFile de entrada, e busca o(s) valor(es) do cache de mapa distribuído associado a cada chave. Se configurado sem um atributo de destino, o conteúdo do FlowFile de entrada é substituído pelos dados binários recebidos pelo cache de mapa distribuído. Se não houver nenhum valor armazenado sob essa chave, o FlowFile será encaminhado para “not-found”. Observe que o processador sempre tentará ler todo o valor armazenado em cache na memória antes de colocá-lo em seu destino. Isso pode ser potencialmente problemático se o valor armazenado em cache for muito grande.
Requisito de entrada¶
REQUIRED
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
Identificador de entrada de cache |
Uma lista delimitada por vírgulas de atributos do FlowFile, ou os resultados de instruções de linguagem de expressão de atributo, que serão avaliados em relação ao FlowFile para determinar o(s) valor(es) usado(s) para identificar duplicatas; são esses valores que são armazenados em cache. NOTE: somente um único identificador de entrada de cache é permitido, a menos que Colocar valor do cache no atributo (Put Cache Value In Attribute) seja especificado. Só há suporte para pesquisas múltiplas de cache quando o destino é um conjunto de atributos (consulte a documentação de “Colocar valor do cache no atributo” para obter mais detalhes, inclusive a convenção de nomenclatura). |
Conjunto de caracteres |
O conjunto de caracteres no qual o valor armazenado em cache é codificado. Isso só será usado no roteamento para um atributo. |
Serviço de cache distribuído |
O Controller Service usado para obter os valores em cache. |
Comprimento máximo para colocar no atributo |
Se você rotear o valor do cache para um atributo do FlowFile (definindo a propriedade “Colocar valor do cache no atributo”), o número de caracteres colocados no valor do atributo será, no máximo, esse valor. Isso é importante porque os atributos são mantidos na memória e atributos grandes causarão rapidamente problemas de falta de memória. Se a saída for maior que esse valor, ela será truncada para caber. Se possível, considere diminuir o tamanho. |
Colocar valor do cache no atributo |
Se definido, o valor do cache recebido será colocado em um atributo do FlowFile em vez de no conteúdo do FlowFile. A chave de atributo a ser colocada é determinada pela avaliação do valor dessa propriedade. Se vários identificadores de entrada de cache forem selecionados, vários atributos serão gravados, usando o valor avaliado dessa propriedade, anexado por um ponto (.) e o nome do identificador de entrada de cache. |
Relações¶
Nome |
Descrição |
|---|---|
failure |
Se não for possível se comunicar com o cache ou se a entrada do cache for avaliada como em branco, o FlowFile será penalizado e encaminhado para essa relação |
not-found |
Se o identificador de entrada de cache do FlowFile não for encontrado no cache, ele será encaminhado para essa relação |
success |
Se a comunicação com o cache for bem-sucedida, ele será encaminhado para essa relação |
Grava atributos¶
Nome |
Descrição |
|---|---|
user-defined |
Se a propriedade “Colocar valor do cache no atributo” estiver definida, o que quer que esteja definido se tornará a chave do atributo e o valor será qualquer que seja a resposta do cache de mapa distribuído. Se vários identificadores de entrada de cache forem selecionados, vários atributos serão gravados, usando o valor avaliado dessa propriedade, anexado por um ponto (.) e o nome do identificador de entrada de cache. Por exemplo, se a propriedade Identificador de entrada de cache for definida como “id,name” e a propriedade definida pelo usuário for denominada “fetched”, serão gravados dois atributos, fetched.id e fetched.name, contendo seus respectivos valores. |