flux 相关问题

我正在使用 RxJava 2 通过 micronaut 框架进行反应式编程。我试图了解以下代码的问题：有趣的 getItemDetails( itemRequest：请求到 ): 单声道我正在使用 RxJava 2 通过 micronaut 框架进行反应式编程。我试图理解以下代码的问题： fun getItemDetails( itemRequest: RequestTo ): Mono<List<ResponseTo>> { return itemRequest.itemIdList.toFlux() .flatMap { findItemStatus(it) } .flatMap { response -> Mono.justOrEmpty(ResponseTo(response)) .onErrorResume { logger.error("Error occurred while mapping entity to response: $response", it) Mono.empty() } } .collectList() } RequestTo：由一个String列表组成。这个想法是迭代这个列表，从数据库中获取每个项目的详细信息（通过返回数据库实体的findItemStatus()函数调用处理）并将其映射到响应对象。我想这样工作，如果 findItemStatus() flatMap 操作返回的任何实体在将其映射到 ResponseTo 时导致异常，我希望在最终列表中跳过该项目但继续处理通量中的剩余项目.我不想将 onErrorResume 块保留在第二个 flatMap 之外，因为如果通量中的任何中间实体在映射时导致错误并且通量中的其余项目将不会被映射，这将关闭流。我不确定我的代码有什么问题，但是当 Mono.justOrEmpty(ResponseTo(response)) 中抛出异常时，它不会在 onErrorResume 中被捕获。我把测试用例放在这里： def "test getItemDetails() when there is an error mapping DB response to Response TO for any item"() { def itemEntity1 = new DiscontinuedItemsEntity("52782904", null, null, UUID.randomUUID()) def itemEntity2 = new DiscontinuedItemsEntity("52778904", null, null, UUID.randomUUID()) def requestBody = new DiscontinuedItemsTcinRequest(["52782904", "52782904"]) when: def response = itemsStatusService.getItemDetails(requestBody).block() def responseList = response.itemsList then: 1 * discontinuedItemsRepository.findDiscontinuedItems(*_) >> Mono.just(itemEntity1) 1 * discontinuedItemsRepository.findDiscontinuedItems(*_) >> Mono.just(itemEntity2) responseList.size() == 1 responseList.get(0).itemId == itemEntity1.itemId } 我需要这个测试用例通过，但是异常被抛出并且没有被处理，因为它没有被 onErrorResume 捕获

java reactive-programming project-reactor flux

回答 0 投票 0

来自多个结果的Influxdb2 influx grafana词云

我目前正在研究 influxdb2 和 flux。我的游乐场是，抓取一个公共网站，并能够在 Grafana 的词云中可视化网站上的文字。这行得通，但是当我的...

grafana flux word-cloud influxdb-2

回答 1 投票 0

如何在 Flux 中将秒数转换为 HH:MM:SS？

我有以下 Flux 查询，提示以秒为单位的平均时差。我需要将其转换为 DD:HH:MM:SS 并显示在 Grafana 中。桶=“测试桶” timeRangeStart = -30d //

influxdb flux influxdb-2 influxdb-python flux-influxdb

回答 0 投票 0

如何在Flux Julia中调整优化器的学习率

如前所述，我试图为我的神经网络实现学习率衰减。我按如下方式设置模型： nn =链（密集（10,5），密集（5,1））选择=亚当（0.01） opt_state = setup(opt, nn) 我试过了……

deep-learning julia flux

回答 1 投票 0

# InfluxDB：如何使用 Flux 添加作为连续行/时间戳差异结果的列？

我是 InfluxDB 和 Flux 查询语言的新手，非常感谢您的耐心等待！很高兴被重定向到文档，但我还没有发现任何真正有用的东西。我有一个简单的时间序列数据...

grafana influxdb flux

回答 1 投票 0

Grafana 没有显示平均值

我试图从我读过的数据中得到一个平均值。最下面的图是我目前收到的数据，上面的数字应该是平均值，但是乍一看，它……

grafana flux

回答 0 投票 0

使用 Flux.train 时如何跟踪损失？

如标题所述，我使用Flux.train训练了我的模型！如下：对于 _ in 1:training_steps_per_epoch Flux.train!(neural_network, data,opt_state) 做 m, x, y 助焊剂...

julia flux

回答 0 投票 0

Spring WebClient 使用 /_bulk api 将 Flux 发送到 ElasticSearch

我想达到的目标：使用 Spring WebClient 通过 /_bulk api 将 Flux 发送到 ElasticSearch。 https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-bulk.html 我...

java elasticsearch flux spring-webclient

回答 2 投票 0

ProjectReactor，在开始使用 Flux 元素之前调用一个方法

如何在 api 管道中调用非 Reactive 阻塞方法，但仅当 Flux 中存在至少一项时才调用它比如这里调用itemsRepo.saveItem之前，我想调用

mono reactive-programming project-reactor flux

回答 0 投票 0

用作 grafana 变量的通量查询，它将返回来自 Influx Cloud 的特定测量中的所有键

我想从特定存储桶中获取特定测量的所有键，以在 Grafana 仪表板上的变量中使用。我相当确定我的开始是正确的：来自（桶：“我的桶......

grafana influxdb flux flux-influxdb

回答 0 投票 0

通量间隔几天后停止，没有任何错误

Reactor Flux 间隔有问题。我有功能 private void startPooling(final XYZ xyz, final Context 上下文) { final Disposable disposable = Flux.interval(Duration.ofMillis(...

java spring spring-boot project-reactor flux

回答 0 投票 0

普通 javascript 中 Flux 模式的减速器

我尝试使用通量模式在 vanilla js 中制作状态管理系统。在设计过程中，我认为1个状态需要1个reducer。但随后需要许多减速器。这是正确的想法吗？ 1 个州是 ne...

javascript flux

回答 1 投票 0

flux 相关问题

最新问题