Floui Filas Internas
Escale e coordene seus processos com facilidade utilizando o gerenciamento de filas
Last updated
Was this helpful?
Escale e coordene seus processos com facilidade utilizando o gerenciamento de filas
Last updated
Was this helpful?
O uso de filas nas execuções de fluxo é uma solução eficaz para lidar com grandes volumes de dados e processos de alta demanda. Essa abordagem permite que as operações sejam escaláveis de maneira segura, garantindo a integridade no consumo dos dados. O gerenciamento de filas no Workspace Floui oferece uma interface intuitiva para que os usuários acompanhem, organizem e controlem tanto o consumo quanto a inserção de dados nas filas.
Será abordado como gerenciar filas no Workspace Floui, as ações disponíveis para manipulação destas filas, e como realizar a inserção e o consumo de dados. Além disso, serão apresentadas boas práticas para otimizar o uso e gerenciamento de filas.
Para acessar o gerenciamento de filas, selecione a opção Filas Internas no menu lateral do Workspace Floui. Nesta seção, serão exibidas informações gerais das filas, como nome, status da fila, grupo associado, e datas de criação e atualização, além das ações disponíveis para cada fila.
Nesta interface, você poderá realizar as seguintes ações:
Criar novas filas;
Editar filas existentes;
Remover filas;
Visualizar detalhes das filas;
Buscar filas específicas;
Filtrar filas por grupos;
Pausar o consumo de filas.
Para criar uma fila, acesse a listagem de filas e clique em Criar nova fila. Insira o nome desejado para a fila e, caso opte, selecione um grupo para associá-la. Utilizar grupos ajuda a organizar os recursos no Workspace de acordo com os contextos da sua operação. Após realizar a parametrização, clique em Salvar Fila para concluir.
A interface de gerenciamento de filas permite que usuários possam coordenar e acompanhar o consumo de filas, porém, a inserção de itens e o seu consumo são feitos dentro da execução do fluxo. Para isso é necessário utilizar os conectores para inserção de fila, Queue Publisher V2, e consumo da fila, Queue Consumer V2.
O conector Queue Publisher V2 é utilizado para publicar um objeto message em uma fila previamente configurada. Após criar a fila, acesse as configurações do conector e selecione-a no campo Fila. Escolha entre enviar o objeto message completo do fluxo ou um objeto personalizado no campo Publicar como. No caso de um objeto personalizado, é possível utilizar a notação Mustache para enviar dados dinâmicos gerados durante a execução do fluxo. Além disso, o conector permite configurar um atraso (em segundos) no envio da mensagem, através do campo Delay. O Delay é útil para controlar a entrada de dados na fila ou atender possíveis limitações temporárias de execução.
O conector Queue Consumer V2, por sua vez, irá realizar o consumo de itens que foram publicados na fila. Este conector é classificado como um Trigger (gatilho), significando que irá realizar a execução do fluxo ao consumir um item da fila, dando início ao processamento daquela mensagem vinda da fila. Para configurar a fila de consumo, acesse as configurações do conector e selecione a fila para consumo através da configuração Fila.
Importante ressaltar alguns pontos sobre o consumo:
Por ser um conector Trigger (gatilho), isto irá contar como uma execução de fluxo a cada item consumido da fila. Consulte os limites de execução da sua conta e a implementação realizada na publicação e consumo de fila para minimizar impactos e controlar o consumo de execuções mensais, caso aplicável ao seu plano.
O consumo ocorre apenas se o fluxo estiver ativo e a fila não estiver com o status de pausa.
O consumo da fila é realizado por apenas um fluxo, e não uma fila para vários fluxos ao mesmo tempo. Ao possuir muitos fluxos ligados a uma mesma fila, somente o primeiro, em relação a ordem de listagem de fluxos, irá realizar o consumo. Acesse a visualização da fila para verificar qual fluxo está ativo para consumo.
Para saber mais detalhes sobre os conectores Queue Consumer V2 e Queue Publisher V2 acesse a documentação destes conectores:
O acompanhamento e controle das filas estão disponíveis apenas para conectores Queue Consumer V2 e Queue Publisher V2, ou novas versões dos mesmos. Os conectores na versão V1 não têm suporte a este controle e estão em depreciação. Recomenda-se que os usuários atualizem seus fluxos, substituindo os conectores V1 pelos da versão mais recente, V2.
Caso o fluxo possua conectores na versão V1, ao tentar salvá-lo com esses conectores, será solicitado para que o fluxo seja editado e que os conectores depreciados sejam removidos. Porém, fluxos criados com conectores V1 anteriores à sua depreciação continuarão funcionando até que sejam completamente descontinuados. Nos fluxos criados a partir de agora, o uso de conectores V1 já não será mais permitido, incentivando o uso da V2, que oferece recursos mais avançados e maior controle sobre as filas.
Após criar uma fila no Workspace Floui e configurar os fluxos responsáveis pela publicação e consumo dessas filas, é possível acompanhar o andamento deste consumo. Para isso, basta acessar a listagem de filas e clicar no botão Visualizar na fila desejada.
A interface de visualização oferece informações detalhadas sobre a fila, incluindo o status atual, o fluxo que está realizando o consumo, os itens (jobs) e seus respectivos estados de processamento. Além disso, é exibido uma pré-visualização dos objetos que serão consumidos e processados pela fila.
Os usuários também têm acesso a opções para realizar o controle da fila, como:
Atualizar dados: Recarregar a página para atualizar os detalhes sobre o consumo.
Pausar/iniciar o consumo: Suspende ou resume o consumo da fila de forma manual.
Limpar fila: Limpa os objetos existentes na fila.
Editar: Acessar a edição de informações da fila.
Os status de consumo da fila também podem ser visualizados tanto na listagem quanto na interface detalhada. Estes status incluem:
O processamento das filas segue o modelo FIFO (First In, First Out), onde a mensagem que foi enviada primeiro será processada antes das demais. O consumo é padronizado para uma execução por segundo, garantindo que apenas uma mensagem seja processada por vez, sem paralelismo.
Além da publicação por conectores, usuários podem adicionar mensagens manualmente à fila, sem a necessidade de usar um fluxo para realizar essa inserção. Para isso, acesse a visualização da fila e clique em Adicionar Mensagem. Configure a mensagem desejada e finalize a criação para disponibilizá-la para consumo pelo fluxo consumidor.
O gerenciamento de filas é um recurso essencial para promover a escalabilidade e o controle das suas operações e integrações. Ao utilizar de forma eficiente, as filas permitem que processos complexos sejam automatizados e escalados com maior segurança e monitorado. A seguir, iremos listar algumas orientações para aprofundar seu conhecimento sobre o gerenciamento de filas e garantir que seus processos sejam escaláveis de maneira confiável, segura e organizada..
Ao criar filas, utilize nomes que sejam descritivos e representem claramente sua finalidade e contexto.
Se possível, agrupe filas de acordo com o seu contexto utilizando o recurso de grupos. Isso facilita o gerenciamento e usabilidade dentro do Workspace.
Antes de iniciar a implementação de publicação e consumo da fila, planeje o volume de dados e a frequência de dados esperado. Isto ajuda a evitar gargalos e reduz o risco de ultrapassar possíveis limites de execução de sua conta.
Considere utilizar um delay na publicação de mensagens para a fila. Isto pode ajudar em casos onde há limitações em integrações externas.
Tratar erros no processamento de mensagens consumidas dentro do seu fluxo.
Considere incluir ações que permitam reprocessar mensagens com falhas ou movê-las para uma fila de erros.
Em um volume alto de consumo, tente enviar as mensagens em lotes para controlar o consumo de execuções do fluxo.
Revise quais fluxos estão vinculados a uma fila para resolver problemas de distribuição. Isto inclui fluxos inativos que estavam vinculados a alguma fila e foram reativados.
Teste suas filas e as lógicas usadas antes de publicá-las em cenários reais.
Em casos onde é necessário escalar o processamento de dados, revise a arquitetura dos fluxos e filas, distribuindo a carga entre filas separadas ou ajustando os limites de processamento. Isso garante que o sistema continue eficiente e confiável, mesmo com volumes crescentes de dados.
.
.
Waiting
A fila está aguardando para ser consumida.
Running
A fila está sendo consumida ativamente.
Paused
O consumo foi pausado manualmente.
