user_client2024/56
1
0
Fork 0
generated from dhairya/scenario_template
Code Issues Pull Requests Packages Projects Releases Wiki Activity

System save at 08/10/2024 13:10 by user_client2024

Browse Source
This commit is contained in:
user_client2024 2024-10-08 07:41:00 +00:00
parent 0a1a673e65
commit 93107e1047
3 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
.ipynb_checkpoints/main-checkpoint.ipynb
View File

@ -83,13 +83,13 @@
"from tms_data_interface import SQLQueryInterface\n",
"\n",
"class Scenario:\n",
" seq = SQLQueryInterface(schema=\"trade_schema\")\n",
" seq = SQLQueryInterface(schema=\"test_schema_test\")\n",
" def logic(self, **kwargs):\n",
" validation_window = kwargs.get('validation_window')\n",
" time_window_s = int(validation_window/1000)\n",
" query_start_time = datetime.now()\n",
" print(\"Query start time :\",query_start_time)\n",
" row_list = self.seq.execute_raw(query.format(trade_data_1b=\"trade_10m_v3\",\n",
" row_list = self.seq.execute_raw(query.format(trade_data_1b=\"test_table_test1\",\n",
" time_window_s = time_window_s)\n",
" )\n",
" cols = [\n",
@ -111,7 +111,7 @@
" final_scenario_df['Risk'] = 'Low Risk'\n",
" final_scenario_df.dropna(inplace=True)\n",
" # final_scenario_df['RUN_DATE'] = final_scenario_df['END_DATE']\n",
" return final_scenario_df\n"
" return final_scenario_df"
]
}
],

6
main.ipynb
View File

@ -83,13 +83,13 @@
"from tms_data_interface import SQLQueryInterface\n",
"\n",
"class Scenario:\n",
" seq = SQLQueryInterface(schema=\"trade_schema\")\n",
" seq = SQLQueryInterface(schema=\"test_schema_test\")\n",
" def logic(self, **kwargs):\n",
" validation_window = kwargs.get('validation_window')\n",
" time_window_s = int(validation_window/1000)\n",
" query_start_time = datetime.now()\n",
" print(\"Query start time :\",query_start_time)\n",
" row_list = self.seq.execute_raw(query.format(trade_data_1b=\"trade_10m_v3\",\n",
" row_list = self.seq.execute_raw(query.format(trade_data_1b=\"test_table_test1\",\n",
" time_window_s = time_window_s)\n",
" )\n",
" cols = [\n",
@ -111,7 +111,7 @@
" final_scenario_df['Risk'] = 'Low Risk'\n",
" final_scenario_df.dropna(inplace=True)\n",
" # final_scenario_df['RUN_DATE'] = final_scenario_df['END_DATE']\n",
" return final_scenario_df\n"
" return final_scenario_df"
]
}
],

4
main.py
View File

@ -80,13 +80,13 @@ FROM
from tms_data_interface import SQLQueryInterface
class Scenario:
seq = SQLQueryInterface(schema="trade_schema")
seq = SQLQueryInterface(schema="test_schema_test")
def logic(self, **kwargs):
validation_window = kwargs.get('validation_window')
time_window_s = int(validation_window/1000)
query_start_time = datetime.now()
print("Query start time :",query_start_time)
row_list = self.seq.execute_raw(query.format(trade_data_1b="trade_10m_v3",
row_list = self.seq.execute_raw(query.format(trade_data_1b="test_table_test1",
time_window_s = time_window_s)
)
cols = [