Rust SDK

注意

Rust SDK 正在开发中， API 可能会在以后的版本中更改。欢迎参与贡献：https://github.com/gorse-io/gorse-rs

安装

[dependencies]
gorse_rs = "0.5.0"

用法

Rust SDK 实现了两个客户端：异步客户端gorse_rs::Gorse和阻塞客户端gorse_rs::blocking::Gorse 。

异步客户端

异步函数中应该使用异步客户端。

use gorse_rs::{Feedback, Gorse, User, Item, RecommendOptions};
use serde_json::json;

#[tokio::main]
async fn main() {
    // Create an async client.
    let client = Gorse::new("http://127.0.0.1:8087", "api_key");

    // Insert a user.
    client.insert_user(&User {
        user_id: "bob".into(),
        labels: json!({
            "company": "gorse",
            "location": "hangzhou, china"
        }),
        comment: "Bob is a software engineer.".into(),
    }).await;

    // Insert an item.
    client.insert_item(&Item {
        item_id: "gorse-io:gorse".into(),
        is_hidden: false,
        labels: json!({
            "topics": ["recommendation", "machine-learning"]
        }),
        categories: vec!["go".into()],
        timestamp: "2022-02-22".into(),
        comment: "Gorse is an open-source recommender system.".into(),
    }).await;

    // Insert feedbacks.
    let feedback = vec![
        Feedback {
            feedback_type: "star".into(),
            user_id: "bob".into(),
            item_id: "ollama:ollama".into(),
            value: 1.0,
            timestamp: "2022-02-24".into(),
        },
        Feedback {
            feedback_type: "star".into(),
            user_id: "bob".into(),
            item_id: "huggingface:transformers".into(),
            value: 1.0,
            timestamp: "2022-02-25".into(),
        },
        Feedback {
            feedback_type: "star".into(),
            user_id: "bob".into(),
            item_id: "rasbt:llms-from-scratch".into(),
            value: 1.0,
            timestamp: "2022-02-26".into(),
        },
        Feedback {
            feedback_type: "star".into(),
            user_id: "bob".into(),
            item_id: "vllm-project:vllm".into(),
            value: 1.0,
            timestamp: "2022-02-27".into(),
        },
        Feedback {
            feedback_type: "star".into(),
            user_id: "bob".into(),
            item_id: "hiyouga:llama-factory".into(),
            value: 1.0,
            timestamp: "2022-02-28".into(),
        },
    ];
    client.insert_feedback(&feedback).await;

    // Get recommendation.
    client.get_recommend("bob", RecommendOptions::default()).await;
}

阻塞客户端

阻塞函数应该使用阻塞客户端。

use gorse_rs::{Feedback, User, Item, RecommendOptions};
use gorse_rs::blocking::Gorse;

fn main() {
    // Create a blocking client.
    let client = Gorse::new("http://127.0.0.1:8087", "api_key");

    // Get recommendation.
    client.get_recommend("bob", RecommendOptions::default());
}