在通过nifi进行了几次数据操作之后,我将数据从csv文件转储到cassandra。我期待来自cassandra的响应消息(为了确保所有数据都被转储),在这个成功/失败消息之后,我需要在下游管道中触发一个以上的api。有谁能帮我从Cassandra那里得到回复信息吗?
9rnv2umw1#
如果没有一个putcassandra处理器传递来自cassandra本身的响应,那么来自客户机的发送/执行(在本例中是nifi)工作或不工作,通常传入的流文件只是相应地传输到success或failure。除非您需要来自“响应”的一些数据,否则只要流文件显示在下游就应该指示它是否工作。如果在对客户机的响应中有一些必要的数据,请随意打开一个改进jira,将其包含在传出流文件中(可能作为属性,以便您以后可以在它们上路由)。
1条答案
按热度按时间9rnv2umw1#
如果没有一个putcassandra处理器传递来自cassandra本身的响应,那么来自客户机的发送/执行(在本例中是nifi)工作或不工作,通常传入的流文件只是相应地传输到success或failure。除非您需要来自“响应”的一些数据,否则只要流文件显示在下游就应该指示它是否工作。
如果在对客户机的响应中有一些必要的数据,请随意打开一个改进jira,将其包含在传出流文件中(可能作为属性,以便您以后可以在它们上路由)。