System save at 23/05/2025 19:41 by user_client2024

This commit is contained in:
user_client2024 2025-05-23 14:11:39 +00:00
parent d4c24d0ad5
commit fd598c35f1
3 changed files with 21 additions and 15 deletions

View File

@ -105,7 +105,7 @@
"\n",
"query = \"\"\"\n",
" SELECT \n",
" t.transaction_id,\n",
" t.transaction_key,\n",
" t.transaction_date,\n",
" t.transaction_amount,\n",
" t.transaction_desc,\n",
@ -162,8 +162,10 @@
" acc_data=\"account_data_v1\",\n",
" alert_data=\"alert_data_v1\")\n",
" )\n",
" \"Focal_id\", \"Cash_deposit_total\", \"Cash_deposit_count\",\n",
" \"Segment\", \"Risk\", \"SAR_FLAG\"\n",
" cols = [\n",
" \"transaction_id\",\n",
" \"Focal_id\",\n",
" \"transaction_date\",\n",
" \"transaction_amount\",\n",
" \"transaction_desc\",\n",
@ -176,9 +178,9 @@
" \"customer_name\",\n",
" \"date_of_birth\",\n",
" \"nationality\",\n",
" \"business_segment\",\n",
" \"risk_level\",\n",
" \"sar_flag\"\n",
" \"Segment\",\n",
" \"Risk\", \n",
" \"SAR_FLAG\"\n",
" ]\n",
" df = pd.DataFrame(row_list, columns = cols)\n",
" return df"

View File

@ -105,7 +105,7 @@
"\n",
"query = \"\"\"\n",
" SELECT \n",
" t.transaction_id,\n",
" t.transaction_key,\n",
" t.transaction_date,\n",
" t.transaction_amount,\n",
" t.transaction_desc,\n",
@ -162,8 +162,10 @@
" acc_data=\"account_data_v1\",\n",
" alert_data=\"alert_data_v1\")\n",
" )\n",
" \"Focal_id\", \"Cash_deposit_total\", \"Cash_deposit_count\",\n",
" \"Segment\", \"Risk\", \"SAR_FLAG\"\n",
" cols = [\n",
" \"transaction_id\",\n",
" \"Focal_id\",\n",
" \"transaction_date\",\n",
" \"transaction_amount\",\n",
" \"transaction_desc\",\n",
@ -176,9 +178,9 @@
" \"customer_name\",\n",
" \"date_of_birth\",\n",
" \"nationality\",\n",
" \"business_segment\",\n",
" \"risk_level\",\n",
" \"sar_flag\"\n",
" \"Segment\",\n",
" \"Risk\", \n",
" \"SAR_FLAG\"\n",
" ]\n",
" df = pd.DataFrame(row_list, columns = cols)\n",
" return df"

12
main.py
View File

@ -94,7 +94,7 @@ import pandas as pd
query = """
SELECT
t.transaction_id,
t.transaction_key,
t.transaction_date,
t.transaction_amount,
t.transaction_desc,
@ -151,8 +151,10 @@ class Scenario:
acc_data="account_data_v1",
alert_data="alert_data_v1")
)
"Focal_id", "Cash_deposit_total", "Cash_deposit_count",
"Segment", "Risk", "SAR_FLAG"
cols = [
"transaction_id",
"Focal_id",
"transaction_date",
"transaction_amount",
"transaction_desc",
@ -165,9 +167,9 @@ class Scenario:
"customer_name",
"date_of_birth",
"nationality",
"business_segment",
"risk_level",
"sar_flag"
"Segment",
"Risk",
"SAR_FLAG"
]
df = pd.DataFrame(row_list, columns = cols)
return df