1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33

use crate::prelude::*;
use jsonpath_lib::Compiled;
use serde_json::Value;
use std::borrow::Cow;

#[cfg(feature = "extract_jsonpath")]
fn extract_json<'a>(expr: &Compiled, json_str: &'a str) -> Option<Cow<'a, str>> {
    serde_json::from_str(json_str).ok().and_then(|value| {
        // TODO: a lot of heap allocations here. Improve json path by adding a take?
        let result = expr.select(&value).ok()?;
        let first = *result.get(0)?;

        match first {
            Value::String(s) => Some(Cow::Owned(s.clone())),
            Value::Null => None,
            v => Some(Cow::Owned(v.to_string())),
        }
    })
}

impl Utf8Chunked {
    /// Extract json path, first match
    /// Refer to https://goessner.net/articles/JsonPath/
    #[cfg(feature = "extract_jsonpath")]
    pub fn json_path_match(&self, json_path: &str) -> Result<Utf8Chunked> {
        match Compiled::compile(json_path) {
            Ok(pat) => Ok(self.apply_on_opt(|opt_s| opt_s.and_then(|s| extract_json(&pat, s)))),
            Err(e) => Err(PolarsError::ValueError(
                format!("error compiling JSONpath expression {:?}", e).into(),
            )),
        }
    }
}