cognite-sdk 0.6.2

SDK for the Cognite Data Fusion API
Documentation
use cognite::assets::*;
use cognite::events::*;
use cognite::files::*;
use cognite::time_series::*;
use cognite::ClientConfig;
use cognite::FilterWithRequest;
use cognite::List;
use cognite::PartitionedFilter;
use cognite::{CogniteClient, Identity, SearchItems};

#[tokio::main]
async fn main() {
    let cognite_client = CogniteClient::new_oidc(
        "TestApp",
        Some(ClientConfig {
            max_retries: 5,
            ..Default::default()
        }),
    )
    .unwrap();
    // List all assets
    let mut filter: AssetFilter = AssetFilter::new();
    filter.name.replace("Aker".to_string());
    match cognite_client
        .assets
        .filter(FilterAssetsRequest {
            filter: Some(filter),
            ..Default::default()
        })
        .await
    {
        Ok(assets) => println!("{} assets retrieved.", assets.items.len()),
        Err(e) => println!("{e:?}"),
    }
    // Retrieve asset
    match cognite_client
        .assets
        .retrieve(&[Identity::from(6687602007296940)], false, None)
        .await
    {
        Ok(asset) => println!("{asset:?}"),
        Err(e) => println!("{e:?}"),
    }
    // Search asset
    let mut asset_search: AssetSearch = AssetSearch::new();
    asset_search.description.replace("Aker".to_string());
    let asset_filter: AssetFilter = AssetFilter::new();
    let assets_search_result: Vec<Asset> = cognite_client
        .assets
        .search(asset_filter, asset_search, None)
        .await
        .unwrap();
    println!("Search found: {:?} assets", assets_search_result.len());
    // List all events
    let event_filter: EventFilter = EventFilter::new();
    let events: Vec<Event> = cognite_client
        .events
        .filter(EventFilterQuery {
            filter: Some(event_filter),
            ..Default::default()
        })
        .await
        .unwrap()
        .items;
    println!("{} events retrieved.", events.len());
    // Search events
    let event_filter_2: EventFilter = EventFilter::new();
    let event_search: EventSearch = EventSearch::new();
    let event_search_result: Vec<Event> = cognite_client
        .events
        .search(event_filter_2, event_search, None)
        .await
        .unwrap();
    println!("Search found {:?} events", event_search_result.len());
    // List all events
    let time_series: Vec<TimeSeries> = cognite_client.time_series.list(None).await.unwrap().items;
    println!("{} time series retrieved.", time_series.len());
    // Search time series
    let time_serie_search: TimeSeriesSearch = TimeSeriesSearch::new();
    let time_serie_filter: TimeSeriesFilter = TimeSeriesFilter::new();
    let time_series_search_result: Vec<TimeSeries> = cognite_client
        .time_series
        .search(time_serie_filter, time_serie_search, None)
        .await
        .unwrap();
    println!(
        "Search found {:?} time series",
        time_series_search_result.len()
    );
    // List all files
    let file_filter: FileFilter = FileFilter::new();
    let files: Vec<FileMetadata> = cognite_client
        .files
        .filter(PartitionedFilter::new(file_filter, None, None, None))
        .await
        .unwrap()
        .items;
    println!("{} files retrieved.", files.len());
    // Search files
    let file_search: FileSearch = FileSearch::new();
    let file_filter_2: FileFilter = FileFilter::new();
    let files_search_result: Vec<FileMetadata> = cognite_client
        .files
        .search(file_filter_2, file_search, None)
        .await
        .unwrap();
    println!("Search found {:?} files", files_search_result.len());
    // List all groups
    match cognite_client.groups.list(None).await {
        Ok(groups) => {
            println!("{} groups retrieved.", groups.items.len());
        }
        Err(e) => println!("{e:?}"),
    }
}