flux 相关问题

应用程序设计范例用作MVC的替代品,由Jing Chen在Facebook上首创

Flux 部署至 EKS 问题

每次使用 Flux 自动将新映像推送到 ECR 时,我都尝试将我的应用程序部署到 AWS EKS。基本上将映像部署到 EKS。我想我已经配置了所有内容,但它不起作用...

回答 1 投票 0

Spring Webflux取消管道并返回flux

我将解释我不知道如何在不使用异常的情况下解决的情况。 情况如下,我将通过测试来解释它,但想象一下有一个返回 Flux 的控制器......

回答 1 投票 0

如何将Flux<T>包装在ResponseEntity中(ResponseEntity<Flux<T>)

首先,我知道还有一些其他问题本质上问同样的事情(How to Wrap Flux in a ResponseEntity、How to mix Flux and ResponseEntity in Spring Webflux controlle...

回答 2 投票 0

Spring WebFlux 检测客户端断开连接

假设以下@RestController: @GetMapping(“听”) 公共 Flux 听(){ return Flux.create(sink -> process(sink)); } 还有某处 下一个(新对象()); 这... 假设以下@RestController: @GetMapping("listen") public Flux<Object> listen() { return Flux.create(sink -> process(sink)); } 还有某个地方 sink.next(new Object()); 此代码没有有关接收器状态或完成的信息 尝试使用isCanceled,每次都返回 false。 是否可以检测到FluxSink是否仍在被客户端使用? 在 spring-webflux 中,如果客户端关闭连接,订阅将被取消并处置。 如果在 process 方法中添加回调 onCancel 和 onDispose 你会看到这一点。 private <T> void process(final FluxSink<T> sink) { sink.onCancel(new Disposable() { @Override public void dispose() { System.out.println("Flux Canceled"); } }); sink.onDispose(new Disposable() { @Override public void dispose() { System.out.println("Flux dispose"); } }); } 然后向您的端点发送一个 http 请求,并在 Flux 完成之前取消它。您将看到两个回调都被触发。 接受的答案仅与“服务器发送事件”结合使用,服务器定期向客户端发送事件,当客户端断开连接时订阅将被取消。正如文档所述https://docs.spring.io/spring-framework/docs/current/reference/html/web-reactive.html#webflux-codecs-streaming 你可以尝试部署到另一台服务器上测试一下,我在本地部署调试的时候也遇到过这个问题。

回答 3 投票 0

如何将数据从influxdb发送到MQTT?

我是 influxdb 的新手,我正在尝试将数据从我的存储桶发送到 MQTT,我已经使用 telegraf 尝试过,但它不起作用,所以我尝试使用 Flux 进行操作,但出现以下错误。 无法前...

回答 1 投票 0

复制 Flux api 图像缺少“src”属性

我在 NextJS 上生成 Flux 图像时遇到了问题。我遇到 Image is Missing src property 错误。我尝试查看 Replicate 的 Flux 文档,但他们没有提及任何内容...

回答 1 投票 0

Overleaf Helm 安装失败;在 <.enabled> 处执行“common.controller.ports”:无法评估类型接口 {}

我正在尝试使用 helm 在我的 kubernetes 集群中安装 Overleaf,我陷入了这个错误,真的不知道如何继续。 错误调用包括:模板:overleaf/charts/common/templates/...

回答 1 投票 0

SpringBoot中如何批量向REST api提交请求?

我有一个批量请求对象的列表,例如 列表批量请求; 我想将它们一一提交到外部 REST API 我已经为此构建了一个 FiegnClient。 有没有什么选择...

回答 1 投票 0

当预期日志丢失时如何调试以下通量代码?

我有这样的代码逻辑,它使用 R-Socket 将消息从一台服务器发送到另一台服务器,整个代码是使用反应器(Flux/Mono)编写的。有时我注意到有些消息不是

回答 1 投票 0

Grafana-类型错误:无法读取未定义的属性(读取“值”)

当我尝试在警报角色下设置查询和警报条件时,我不断收到以下错误。我搜索其他博客无法解决这个问题 发生意外错误 细节 键入...

回答 1 投票 0

在Python中,扩散器不充当ComfyUI

小伙伴们,最近我在尝试通过python使用flux图像生成器。我使用了许多 UI,如 ComfyUI 和其他 UI,但我对在 python 中使用 Flux 感到好奇,这样我就可以构建自己的......

回答 1 投票 0

使用 Flux 聚合和计算重复消息

我有一个来自日志文件的表,其中的值将日志消息表示为字符串。消息经常重复,因此使用查询: 来自(桶:“my_bucket”) |> 范围(开始:v.timeRang...

回答 1 投票 0

Flux Terraform 控制器未选择正确的 Terraform 状态

我有一个与 Github 提供商一起运行的 Flux terraform 控制器,但是,它似乎选择了错误的 Terraform 状态,因此它不断尝试一次又一次地重新创建资源(并且

回答 1 投票 0

团队的 Flux 通知与 Slack 通知并行

系统管理员希望我执行以下操作: 我们需要与 Slack 通知并行地为 Teams 设置 Flux 通知。将开发人员添加到 Teams 频道会更容易,因为他们已经拥有 Teams

回答 1 投票 0

flux 与 linkerd 和证书管理器存在颁发者错误

我正在安装 Linkerd Helm verison,带有 Flux 和 TLS 旋转的证书管理器 证书管理器保存默认配置,因此没有太多可说的 Flux 和 Linkerd 具有以下配置: 发布.yaml

回答 1 投票 0

Java Flux 异常处理?

有人可以指导我吗,因为我是新的变化并试图了解如何处理这种情况? 问题:我在 getResp() 方法的通量响应之一中遇到 readTimeout 异常

回答 1 投票 0

Azure AKS GitOps 如何决定从哪个集群目录进行引导?

大多数“flux boostrap”CLI 示例显示了如何使用参数“--path”来指向“/clusters/staging”等目录来引导配置。 使用 Azure 时

回答 1 投票 0

Flux 总是返回 null 或空

我有这个 GET 控制器 @GetMapping("/测试") 公共通量测试(){ 返回 Flux.just("Test1", "test2") .delayElements(Duration.ofSeconds(1)) ....

回答 1 投票 0

如何像Mono一样在expediagroup graphql中实现reactor Flux?

我正在尝试以与Mono类似的方式为Flux编写数据获取器,并使用下面的代码返回CompletableFuture,但这总是返回null。?如何在 graphql 中支持 Flux expediagroup

回答 1 投票 0

在 Grafana 仪表板中添加变量

我想添加一个自定义变量,它允许我过滤“process”的标签值等于grafana仪表板中的变量值的数据。我可以向

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.