Lib.rs

New Relic SDK for 异步任务（tokio 和 actix）

它是对 newrelic SDK 的包装。

用法

tokio-newrelic = "*"

导出变量

export ENABLE_NEW_RELIC="true"
export NEW_RELIC_LICENSE_KEY="newrelic_license_key"
export NEW_RELIC_APP_NAME="app_name"

use tokio_newrelic;

// actix api function
#[get("/")]
async fn index(_req: HttpRequest) -> impl Responder {
    let t = newrelic_transaction_function().await;
    HttpResponse::Ok().body(format!("index_page {:?}", t))
}

pub async fn newrelic_transaction_function1() -> Option<i32> {
    // Mandatory wrapping, with newrelic for setting task scope 
    // starting a web transaction and storing it to a tokio::Localtask 
    let r = tokio_newrelic::execute("web_transaction_name", async move {
        self::abc1().await;
        db_test();
        db_test_pooled_connection();
        std::thread::sleep(std::time::Duration::from_secs(2));
        Some(2)
    })
    .await;
    r
}

pub fn db_test_pooled_connection() {
    println!("pg_db_test_pooled_connection");
    let database_url = "postgres://[email protected]/acko";
    let pooled_conn = tokio_newrelic::pg_pool::connection_with_url(database_url);
    query(&pooled_conn);
}


pub fn db_test() {
    println!("pg_db_test");
    let database_url = "postgres://[email protected]/acko";
    let nr_conn = tokio_newrelic::pg::NConnection::establish(database_url)
        .expect(&format!("Error connecting to {}", database_url));
    query(&nr_conn);
}

测试

 for ((i=1;i<=100;i++)); do seq 1 200 | xargs -n2 -P20  curl "http://127.0.0.1:3000/"; done

• 希望您已经有所了解，更多详细信息请参阅示例目录。
• 此包仅实现了数据存储段。

• 段
  • 数据存储
  • 自定义
  • 外部
  • 嵌套段
  • 覆盖计时

需要运行 c-sdk 守护进程

此包需要按照文档运行 newrelic 守护进程 Newrelic 文档;