#update

qapro-rs/Cargo.toml

@@ -137,6 +137,7 @@ features = [
   "string_encoding",
   "product",
   "ndarray",
+  "parquet"
 ]
 
 [dependencies.clickhouse-rs]

qapro-rs/src/main.rs

@@ -56,9 +56,9 @@ async fn main() {
     // 初始化 Monitor管理
     let morm_addr = MonitorManager::new(count).await.start();
 
-    let mut cash_map: HashMap<String, f64> =
+    let cash_map: HashMap<String, f64> =
         serde_json::from_str(&format!(r#"{}"#, CONFIG.accsetup.cash_map)).unwrap();
-    let backtest_start = get_n_day_before_date9(20);
+    let _backtest_start = get_n_day_before_date9(20);
 
     let mut all_hisdata: HashMap<String, Vec<QAKlineBase>> = HashMap::new();
     for code in codes.iter() {
@@ -130,6 +130,6 @@ async fn main() {
     println!("all histdata is cleaned");
     // system.run();
 
-    let (tx, rx) = futures::channel::oneshot::channel::<()>();
-    rx.await;
+    let (_tx, rx) = futures::channel::oneshot::channel::<()>();
+    rx.await.unwrap();
 }

qapro-rs/src/parsers/lang.rs

@@ -3,7 +3,7 @@ use std::str::FromStr;
 use parse_display::{Display, FromStr};
 
 
-use polars::prelude::CsvReader;
+
 
 use polars::prelude::*;
 

qapro-rs/src/parsers/models.rs

@@ -39,7 +39,7 @@ impl fmt::Display for Array {
         for atom in self.data.iter() {
             writeln!(f, "  {},", atom);
         }
-        writeln!(f, ">>");
+        writeln!(f, ">>")?;
         Ok(())
     }
 }

qapro-rs/src/parsers/sql/env.rs

@@ -1,4 +1,3 @@
-use std::collections::VecDeque;
 
 use indexmap::IndexMap as Map;
 

qapro-rs/src/qaconnector/mongo/mongoclient.rs

@@ -93,7 +93,7 @@ impl QAMongoClient {
 
     pub async fn save_account(&self, mut account: QA_Account) {
         // 实时切片
-        let mut slice: QIFI = account.get_qifi_slice();
+        let slice: QIFI = account.get_qifi_slice();
         self.save_qifi_slice(slice).await;
     }
 
@@ -109,10 +109,10 @@ impl QAMongoClient {
             doc! {"account_cookie": slice.account_cookie},
             v,
             UpdateOptions::builder().upsert(Option::from(true)).build(),
-        );
+        ).unwrap();
     }
 
-    pub async fn save_his_qifi_slice(&self, mut slice: QIFI) {
+    pub async fn save_his_qifi_slice(&self, slice: QIFI) {
         let coll = self
             .client
             .database(CONFIG.account.db.as_str())
@@ -123,7 +123,7 @@ impl QAMongoClient {
             doc! {"account_cookie": slice.account_cookie,"trading_day":trading_day},
             v,
             UpdateOptions::builder().upsert(Option::from(true)).build(),
-        );
+        ).unwrap();
     }
 
     pub async fn save_accounthis(&self, mut account: QA_Account) {
@@ -139,6 +139,6 @@ impl QAMongoClient {
             doc! {"account_cookie": slice.account_cookie,"trading_day":trading_day},
             v,
             UpdateOptions::builder().upsert(Option::from(true)).build(),
-        );
+        ).unwrap();
     }
 }

qapro-rs/src/qadata/resample.rs

@@ -3,7 +3,7 @@ use crate::qaprotocol::mifi::qafastkline::QAKlineBase;
 use crate::qaprotocol::qifi::account::QIFI;
 use chrono::format::ParseError;
 use chrono::{DateTime, FixedOffset, NaiveDate, NaiveDateTime, NaiveTime, TimeZone, Utc};
-use serde::{Deserialize, Serialize};
+use serde::Serialize;
 
 #[derive(Debug, Clone)]
 pub struct QARealtimeResampler {