Apache Cassandra 支持

paranoid lv.1

发布时间：2022-12-10 12:56:12 269

卡桑德拉出站组件

这是一个实现，可以在单向（默认）和请求-答复模式（选项）下工作。默认情况下，它是异步的（重置），并对提供的执行反应式、或操作。可以通过该选项配置操作类型。将模式设置为 ;或、或将模式设置为 .CassandraMessageHandlerAbstractReplyProducingMessageHandlerproducesReplysetAsync(false)INSERTUPDATEDELETESTATEMENTReactiveCassandraOperationsCassandraMessageHandler.TypeingestQueryINSERTquerystatementExpressionstatementProcessorSTATEMENT

以下代码片段演示了此通道适配器或网关的各种配置：

@Bean
IntegrationFlow cassandraSelectFlow(ReactiveCassandraOperations cassandraOperations) {
    return flow -> flow
            .handle(Cassandra.outboundGateway(cassandraOperations)
                    .query("SELECT * FROM book WHERE author = :author limit :size")
                    .parameter("author", "payload")
                    .parameter("size", m -> m.getHeaders().get("limit")))
            .channel(c -> c.flux("resultChannel"));
}

如果在默认异步模式下将 a 用作网关，则生成 a，根据提供的实现进行处理。对于真正的反应式处理，建议对输出通道配置使用。在同步模式下调用以获取回复值。CassandraMessageHandlerMonoMessageChannelFluxMessageChannelMono.block()

如果执行或操作，则请求消息有效负载中应有一个实体（标记为）。如果有效负载是实体列表，则执行相应的批处理操作。INSERTUPDATEDELETEorg.springframework.data.cassandra.core.mapping.Table

该模式期望有效负载以要插入的值矩阵的形式存在 - 。例如，如果实体如下所示：ingestQueryList<List<?>>

@Table("book")
public record Book(@PrimaryKey String isbn,
                   String title,
                   @Indexed String author,
                   int pages,
                   LocalDate saleDate,
                   boolean isInStock) {

}

通道适配器具有以下配置：

@Bean
public MessageHandler cassandraMessageHandler3() {
    CassandraMessageHandler cassandraMessageHandler = new CassandraMessageHandler(this.template);
    String cqlIngest = "insert into book (isbn, title, author, pages, saleDate, isInStock) values (?, ?, ?, ?, ?, ?)";
    cassandraMessageHandler.setIngestQuery(cqlIngest);
    cassandraMessageHandler.setAsync(false);
    return cassandraMessageHandler;
}

请求消息有效负载必须按如下方式转换：

List<List<Object>> ingestBooks =
    payload.stream()
            .map(book ->
                    List.<Object>of(
                            book.isbn(),
                            book.title(),
                            book.author(),
                            book.pages(),
                            book.saleDate(),
                            book.isInStock()))
            .toList();

文章来源： https://blog.51cto.com/u_15326439/5920840

特别声明：以上内容（图片及文字）均为互联网收集或者用户上传发布，本站仅提供信息存储服务！如有侵权或有涉及法律问题请联系我们。