Rust Tokio - 监控停滞的任务-6ren

Rust Tokio - 监控停滞的任务

转载作者：行者123 更新时间：2023-12-03 11:29:15

27

4

我在 prod 中运行一个 rust Tokio 应用程序。在上一个版本中，我有一个错误，一些请求导致我的代码进入无限循环。
发生的事情是当进入无限循环的任务卡住时，所有其他任务继续正常工作并处理请求，直到停顿任务的数量高到足以导致我的程序无响应。
我的问题是我们的监控系统花了很多时间来识别出问题。例如:回答 kubernetes 健康检查的任务运行良好，但我无法确定我的系统中的任务已停止。
所以我的问题是我是否有办法在这种情况下识别和提醒？
例如:如果我能找到定义任务超时的方法，并且如果它在 X 秒/毫秒后没有返回到调度程序 - 此任务将标记为已停止，这对我来说将是一个很好的解决方案。

最佳答案

使用 tracing这里可能是一个选项:关注 issue 2655每个 tokio 任务都应该有一个跨度。除了tracing-futures，这意味着您应该在每次进入或暂停任务(see this example)时获得一个跟踪事件，通过添加相关数据(例如任务ID/请求ID/...)，您应该能够提供将此信息传递给分析工具，以便了解:

一个任务被阻塞(被恢复然后再也没有挂起)

如果您添加自己的跨度，则“用户空间”跨度永远不会退出/关闭，这可能意味着它卡在非阻塞循环中(这也是一个问题，尽管问题不大)

我认为这就是它的程度:正如 issue 2510 所指出的那样，tokio 还没有使用它生成的跟踪信息，因此没有提供“内置”自省(introspection)工具。

关于Rust Tokio - 监控停滞的任务，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/65696879/

27

4

0

文章推荐： javascript - 在强类型 View 中使用 JavaScript

文章推荐： javascript - 添加和删除 html 元素到 jquery 变量

rust - Tokio 错误: "there is no reactor running"即使安装了 #[tokio::main] 和单个版本的 tokio
当运行这样的代码时: use futures::executor; ... pub fn store_temporary_password(email: &str, password: &str) -
Why do I get the error "there is no reactor running, must be called from the context of Tokio runtime" even though I have #[tokio::main]?(为什么即使我有#[Tokio：：Main]，我也会收到错误“There is no Reector Running，Main Be Call from the Tokio Runtime”？)
我遵循了mdns Rust文档并粘贴了示例代码，但它抛出了以下错误：。以下是我拥有的代码：。依赖关系：。我遗漏了什么？我试着在网上寻找，但没有找到如何为这个用例创建一个反应堆。
rust - 什么时候应该使用 tokio::join!() 而不是 tokio::spawn()？
假设我想与 Tokio 同时下载两个网页... 要么我可以用 tokio::spawn() 来实现这个: async fn v1() { let t1 = tokio::spawn(reqwe
asynchronous - 如何在不使用 tokio::spawn 的情况下循环运行多个 Tokio 异步任务？
我制作了一个还能显示天气的 LED 时钟。我的程序在一个循环中做了几件不同的事情，每件事都有不同的间隔: 每 50 毫秒更新一次 LED，每 1 秒检查一次光照水平(以调整亮度)，每 10 分钟获
asynchronous - 如何在不使用 tokio::spawn 的情况下循环运行多个 Tokio 异步任务？
我制作了一个还能显示天气的 LED 时钟。我的程序在一个循环中做了几件不同的事情，每件事都有不同的间隔: 每 50 毫秒更新一次 LED，每 1 秒检查一次光照水平(以调整亮度)，每 10 分钟获
rust - tokio::run_async 与 tokio::net::UnixStream panic
tokio::run_async + futures 0.3 + tokio::net::UnixStream panic 。设置 [package] name = "prac" version =
rust - 错误 E0412:导入 tokio::sync 时使用未声明的 crate 或模块 `tokio`
在我的 rust 项目中，cargo 提示使用 tokio::sync 时使用的类型不在范围内: use tokio::sync::RwLock; | ^^^^^ use of undec
postgresql - 如何在 tokio_postgres 中使用自定义 Tokio 运行时(并且没有 tokio::main 宏)？
我将如何使用自定义 tokio 运行时构建器并且没有主宏来实现这个 tokio_postgres 示例？这工作正常，根据 tokio_postgres docs : 示例/withmacro.rs
asynchronous - 从 Tokio 应用程序使用 Actix:混合 actix_web::main 和 tokio::main？
目前我有一个主要的写成 async example for the Reqwest library . #[tokio::main] async fn main() -> Result> { 我们可以
rust - 即使我有＃[tokio::main]，为什么仍然出现错误 “there is no reactor running, must be called from the context of Tokio runtime”？
我遵循the mdns Rust documentation并粘贴了示例代码，但它引发以下错误: thread 'main' panicked at 'there is no reactor runn
rust - 如何解决 "the trait bound ` [closure]: tokio::prelude::Future` is not satisfied"when calling tokio::spawn?
extern crate tokio; // 0.1.22 use tokio::io; use tokio::net::TcpListener; use tokio::prelude::*; use
rust-tokio - 如何将超响应正文写入文件？
我正在尝试使用 tokio 编写一个测试程序，该程序从网站获取文件并将流式响应写入文件。 hyper 网站显示了一个使用 while 循环并使用 .data() 的示例。方法响应主体，但我想用 .ma
Rust Tokio - 监控停滞的任务
我在 prod 中运行一个 rust Tokio 应用程序。在上一个版本中，我有一个错误，一些请求导致我的代码进入无限循环。发生的事情是当进入无限循环的任务卡住时，所有其他任务继续正常工作并处理请求
rust - Tokio 任务在完成前退出
下面的程序应该从多个线程定期打印，但是 tokio::time::sleep没有按我预期的那样工作: use tokio::prelude::*; //0.3.4 use tokio::runtime
rust - Tokio 任务能否优雅地终止整个运行时？
我使用如下代码启动 Tokio 运行时: tokio::run(my_future); 我的 future 继续启动一堆任务以响应各种条件。其中一项任务负责确定程序何时关闭。但是，我不知道如何让该任
rust - 如何在不阻塞父任务的情况下在另一个任务中生成长时间运行的 Tokio 任务？
我正在尝试构建一个可以管理来自 websocket 的提要但能够在多个提要之间切换的对象。有一个 Feed 特征: trait Feed { async fn start(&mut self
multithreading - 如何从标准库生成的线程向 Tokio 异步任务发送消息？
我有一个设置，我的程序使用 std::thread::spawn 为 CPU 绑定(bind)计算生成多个线程。我需要一个 GRPC 服务器来处理传入的命令并流式传输工作线程完成的输出。我正在为 G
rust - 为什么需要像 Tokio 这样的异步运行时？
我做计算机系统项目的第一个经历是使用 vanilla Java 构建服务器，然后在 Android 手机上构建客户端。从那时起，我发现有很多框架可以帮助管理可伸缩性并消除编写样板代码的需要。我正在尝
Delphi Tokio IDE - 有什么自定义方法吗？
我将从 Delphi XE4 迁移到 10.2。新的单位名称样式(深灰色背景上的黑色文本)不适合我的视力。有人可以建议如何更改它，最好不使用第 3 方加载项吗？这就是新样式的样子，我很难阅读事件单位
rust - tokio::time::sleep方法是否将任务从运行队列中移出？
我一直在寻找tokio源代码来获取问题的答案，并且给人以the sleep method literally puts a timer with duration的印象，但是我认为我可能误解了代码，因

首页

博学

6Ren·AI

商城

Rust Tokio - 监控停滞的任务