nacos-sdk-rust binding for Python

这篇具有很好参考价值的文章主要介绍了nacos-sdk-rust binding for Python。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

广告时间

nacos-sdk-rust-binding-py : nacos-sdk-rust binding for Python with PyO3.

Tip: nacos-sdk-python 仓库暂未提供 2.x gRPC 交互模式，为了能升级它，故而通过 ffi 方式调用 nacos-sdk-rust

py 包 -> https://pypi.org/project/nacos-sdk-rust-binding-py

客官，走过路过不要错过，买不买瞧一瞧也是好的。行过路过唔好错过啦👆～

缘起？冲突！

啊哈？哪有那么多理由！就是闲来无事，想试试 binding for Python …

的确不像 nacos-sdk-rust-binding-node 有实际的需求，但也偶尔在 Nacos 社区用户群里看到有人问 nacos-sdk-python 是否支持 gRPC ；虽也想提供些帮助，之前也了解有 PyO3 神器，但确实不懂 Python 这门语言。

这不是巧了吗这不是

也是偶然，近来转岗到新部门，恰逢上手新工作有个文档记录了黑屏操作的 py 脚本 😂 ；而我作为负责人刚好又要提供它给内部用户，若我不理解脚本干了啥那说不过去；唯有尝试看了看，emmmm 语法确实不难，简单易理解。

前些天阅览了这篇文章「为 Databend Rust Driver 实现 Python Binding」，我可记着它，会有一日能实现 nacos-sdk-rust binding for Python

周末～闲来无事！开搞～

How? PyO3 + Maturin

Rust 和 Python 都拥有丰富的包和库。在 Python 中，很多包的底层是使用 C/C++ 编写的，而 Rust 天生与 C 兼容。因此，我们可以使用 Rust 为 Python 编写软件包，实现 Python 调用 Rust 的功能，从而获得更好的性能和速度。

为了实现这一目标，PyO3 应运而生。PyO3 不仅提供了 Rust 与 Python 的绑定功能，还提供了一个名为 maturin 的开箱即用的脚手架工具。通过 maturin，我们可以方便地创建基于 Rust 开发的 Python 扩展模块。这样一来，我们可以重新组织代码，使用 Rust 编写性能更好的部分，而其余部分仍然可以使用原始的 Python 代码。

– 摘自「为 Databend Rust Driver 实现 Python Binding」

除了「Databend Rust Driver」还借鉴 PyO3 examples wasmer-python 等些项目，以及「Python3 教程 | 菜鸟教程」

由 maturin 初始化项目，仅需十来个提交完成基本可用的功能
nacos-sdk-rust binding for Python

难点

python 默认非 aysnc ?
a. maturin 构建提示 Rust 的绑定代码不能写 async 方法！
b. 若 async ，py 应该是要借助 asyncio 库来支持，没深入理解也暂时让使用成本低，故而启用了非 async 的 nacos-sdk-rust 。
python 函数被 Rust 调用
a. Nacos 配置监听、服务订阅，这些 callback 函数需要由 py 用户实现逻辑作为参数传入。

第二点在 wasmer-python/packages/api/src/externals/function.rs 找到了借鉴，所以 Nacos Config Listener 绑定方法实现如下

#[pyo3(signature = (data_id, group, listener))]
pub fn add_listener(
    &self,
    py: Python,
    data_id: String,
    group: String,
    listener: &PyAny, // PyFunction arg: <NacosConfigResponse>
) -> PyResult<()> {
    if !listener.is_callable() {
        return Err(PyErr::new::<PyValueError, _>(
            "Arg `listener` must be a callable",
        ));
    }
    self.inner
        .add_listener(
            data_id,
            group,
            Arc::new(NacosConfigChangeListener {
                func: Arc::new(listener.to_object(py)),
            }),
        )
        .map_err(|nacos_err| PyRuntimeError::new_err(format!("{:?}", &nacos_err)))?;
    Ok(())
}

pub struct NacosConfigChangeListener {
    func: Arc<PyObject>,
}

impl nacos_sdk::api::config::ConfigChangeListener for NacosConfigChangeListener {
    fn notify(&self, config_resp: nacos_sdk::api::config::ConfigResponse) {
        let ffi_conf_resp = transfer_conf_resp(config_resp);

        // call PyFunction with args
        let _ = Python::with_gil(|py| -> PyResult<()> {
            let _ = self.func.call(py, (ffi_conf_resp,), None);
            Ok(())
        });
    }
}