import gradio as gr
# from langchain.vectorstores import Chroma
'''
https://huggingface.co/spaces/kevinhug/clientX
https://hits.seeyoufarm.com/
'''
'''
PORTFOLIO OPTIMIZATION
'''
from aiOpt import Asset
import numpy as np
def optimize(cost, prob, its):
s = Asset(np.asfarray(cost.split()),
np.asfarray(prob.split()))
return s.random_restart(int(its))
'''
TIME SERIES ANALYTICS
'''
import pandas as pd
import plotly.express as px
def trend(t):
'''
import yfinance as yf
from sklearn.preprocessing import StandardScaler
data = yf.download(t, period="3mo")
for c in t.split(' '):
q=data.loc[:,('Close',c)]
data.loc[:,('Close_MA',c)]=q.rolling(9).mean() -q.rolling(42).mean()
q=data.loc[:,('Volume',c)]
data.loc[:,('Volume_MA',c)]=q.rolling(9).mean() -q.rolling(42).mean()
ma=data.loc[:,["Volume_MA","Close_MA"]].tail(15)
std=StandardScaler()
result=std.fit_transform(ma)
df=pd.DataFrame(result,columns=ma.columns)
d=df.tail(1).stack(level=-1).droplevel(0, axis=0)
'''
d=pd.read_pickle("data.pkl")
'''
https://www.gradio.app/docs/plot
fig = px.line(df, x="day", y=countries)
fig.update_layout(
title="Outbreak in " + month,
xaxis_title="Cases",
yaxis_title="Days Since Day 0",
)
return fig
'''
fig=px.scatter(d, x="Close_MA", y="Volume_MA",color='ticker')
fig.update_layout(
title="Top Right is the Growth Industry",
xaxis_title="Trend in Price",
yaxis_title="Trend in Volume",
)
return fig
#return gr.ScatterPlot(d, x="Close_MA", y="Volume_MA",color='ticker')
'''
SIMILAR VECTOR DB SEARCH
'''
import chromadb
client = chromadb.PersistentClient(path="chroma.db")
db = client.get_collection(name="banks")
def similar(issue):
global db
docs = db.query(query_texts=issue, n_results=5)
return docs
'''
FINE TUNE LLM LIKE SCORE
'''
from fastai.text.all import *
import pathlib
p=pathlib.Path('./banks_txt_like.pkl').resolve()
'''
NotImplementedError: cannot instantiate ‘WindowsPath’ on your system
'''
import platform
plt = platform.system()
if plt == 'Windows':
pathlib.PosixPath = pathlib.WindowsPath
else:
pathlib.WindowsPath = pathlib.PosixPath
learn = load_learner(p)
def like(issue):
pred,idx,probs = learn.predict(issue)
return pred
'''
EXPLAINABLE AI
'''
'''
https://www.gradio.app/docs/interface
'''
with gr.Blocks() as demo:
'''
https://hits.seeyoufarm.com/
https://dash.elfsight.com
'''
counter="""
"""
# gr.HTML(counter)
gr.Markdown("""Enhancing Customer Engagement and Operational Efficiency with NLP
=========
1) Semantic Similarity Document Search (SSDS)
2) Fine Tune LLM
3) Trading Analytic: Using Time Series Data to Identify Growth
4) Portfolio Optimization with cost, probabilities
#### Data Scientist: Kevin Wong, objectdeveloper@gmail.com, 416-903-7937
##### Open source ml bank dataset,
__I'm just using a small sample of this data set for demo__
https://www.kaggle.com/datasets/trainingdatapro/20000-customers-reviews-on-banks/?select=Banks.csv
[](https://hits.seeyoufarm.com)
""")
with gr.Tab("Semantic Similarity Document Search (SSDS)"):
in_similar = gr.Textbox(placeholder="having credit card problem",
label="Issue",
info="issue you want to explore about"
)
out_similar = gr.JSON(label="Similar Verbatim")
btn_similar = gr.Button("Find Similar Verbatim")
btn_similar.click(fn=similar, inputs=in_similar, outputs=out_similar)
gr.Examples(
[
["having credit card problem"],
["low interest credit card"],
["loan"],
["upset customer"],
["what is the password"],
],
[in_similar]
)
gr.Markdown("""
Description:
=======
In today's dynamic financial landscape, the Semantic Similarity Document Search (SSDS) capability is a practical innovation to improve client experience, marketing leads, and sentiment analysis. As a Data Scientist with a decades in the financial industry, I see the value of SSDS in action.
Investment Portfolio Construction/Marketing Leads:
------
To enhance marketing strategies, SSDS identifies market trends and consumer preferences, such as the demand for low-interest credit cards, and GIC. It's a treasure trove for refining our product offerings to the targeted customer according to their credit score, risk appetite, demographic, collateral, capital, and economic conditions, enhancing the lift and efficiency of the recommendation process.
Combining **SingleStore MEMSQL/Kafka structured streaming** for a real-time recommendation for closing sales at the right time in the right channel.
Optimize your Asset Allocation with your objective function and cost function.
### issue:
- low interest credit card
- GIC
AML/KYC/Compliance/Audit/Cyber Security/Fraud Analytics/Observability:
------
### vite vue chart.js UI demo
https://kevinwkc.github.io/davinci/
### Proactive Detection: Identify potential fraud threats and vulnerabilities in real-time.
Customer-Centric Approach: Gain insights into customer concerns, allowing us to address them promptly.
#### issue:
- what is the password
Client Experience:
------
When a client faces a bad experience, SSDS helps us swiftly locate relevant documents to understand and address their concerns, be it credit card issues, late payment fees, or credit score drops.
### issue:
- having bad client experience
- having credit card problem
- late payment fee
- credit score dropping
Sentiments:
------
SSDS tracks customer sentiment, empowering us to swiftly respond to upset customers. It ensures we address their issues promptly, enhancing trust and loyalty.
With no need for jargon, SSDS delivers tangible value to our fintech operations. It's about staying agile, informed, and customer-centric in a rapidly changing financial world.
### issue:
- upset customer
""")
with gr.Accordion("Future Improvement"):
gr.Markdown("""
tuning the distance for use case
""")
with gr.Tab("Explainable AI"):
gr.Markdown("""
Explain by Dataset
sorted feature from top(most import)
dist_subway when at low value(green) make big impact to price
dist_store doesnt make much impact to price
high age lower the price
low age raise the price
Explain by Feature
=============
dist lower than 900 spike the price f(x)
also highlighted the shap value for record[20] at around 6500
Explain by Record
=============
the largest contribution to positive price is dist_subway
second contribution is age
""")
with gr.Tab("Fine Tune LLM"):
in_like = gr.Textbox(placeholder="having credit card problem" , label="Issue",
info="issue you want to explore about")
out_like = gr.Textbox(placeholder="like score in range [2 to 248] from fine tuning data",
label="like score",
info="like score")
btn_like = gr.Button("Classify Like Score")
btn_like.click(fn=like, inputs=in_like, outputs=out_like)
gr.Examples(
[
["having credit card problem"],
["low interest credit card"],
["loan"],
["upset customer"],
["what is the password"],
],
[in_like]
)
gr.Markdown("""
Smart Insights: Elevating Customer Engagement Through Sentiment Analysis
=========
As a Data Scientist with a decades of financial industry experience, I recognize the paramount importance of staying closely tuned to our customer's needs and opinions. In this app, Fine Tune LLM, we have shown how fine-tuning a Language Model (LLM) on a custom dataset can provide valuable insights into customer sentiment across crucial areas such as service, sales, point of failure, product, and emerging trends.
Objective:
---------
Our aim is to extract meaningful insights from customer interactions to improve our services, products, and overall customer experience. This analysis will help us understand what our customers are discussing and how they feel about different aspects of our business.
Use Case:
- intervene attrition through incentive
""")
with gr.Tab("Trading Analyics"):
in_ts = gr.Textbox(placeholder="XLE XLV XLY XLK XLF XLP XLI XLRE XLU",
label="Ticker",
info="Technical Difficult: Currently it only works with these tickers due to data pulling constraints"
)
plot = gr.Plot()
#plot = gr.Plot(label="Identify Trend/Decline Industry")
btn_ts = gr.Button("Find Trending Industry")
btn_ts.click(fn=trend, inputs=in_ts, outputs=plot)
gr.Markdown("""
Maximizing Trading Efficiency: Personalize Your Asset Allocation for Optimal Growth
=========
The industry life cycle is a useful tool for traders to identify growth and decline industries. It describes the evolution of an industry based on its stages of growth and decline
#### There are four phases of the industry life cycle: introduction, growth, maturity, and decline
By identifying growth and decline industries, traders can make informed investment decisions and speed up trading by investing in companies that are likely to experience growth in the future and avoiding companies that are likely to experience a decline in the future.
- Long Trader: buy growth industry
- Short Trader: sell decline industry
#### Personalize objective function and cost function for each trader
- cost function can prevent selecting decline industry
we can use this to filter out blacklisted firms for compliance
we can increase the cost for highly correlated stock for diversity
- objective function can identify potential industry
#### Personalize UI to fit each trader
customize UI for secret sauce formula for stock picking:
- metric: moving average for the price, moving average for volume, ...etc
- timeframe chain: monthly, weekly, daily, 4h, 15 min
##### tableau portfolio
https://public.tableau.com/app/profile/kevin1619
##### vite vue chart.js UI demo
https://kevinwkc.github.io/davinci/
#### Personalize Alert with Twilio
The trader can set their price to buy at the right price at the right time, without missing the right entry in a high stress environment
#### Keeping record for compliance
The System can save data for reporting or compliance purpose
""")
with gr.Tab("Portfolio Optimization"):
in_p_cost = gr.Textbox(value="4 30 2 3 5",
label="Cost",
info="cost for the asset"
)
in_p_prob = gr.Textbox(value="0.3 0.4 0.5 0.6 0.7",
label="Probabilities",
info="P(success) for the asset"
)
in_p_its = gr.Textbox(value="10",
label="Number of Iteration",
info="number of trial for optimal"
)
out_p = gr.Textbox(label="Asset Allocation Approx Optimization using AI")
btn_p = gr.Button("Optimize Asset Allocation")
btn_p.click(fn=optimize, inputs=[in_p_cost, in_p_prob, in_p_its], outputs=out_p)
gr.Markdown("""
Objective: To allocate assets in a way that maximizes expected profit while minimizing costs and risks.
Inputs:
- List of available assets and their associated probabilities and costs.
Outputs:
- Allocation of assets that maximizes expected profit while minimizing costs and risks.
Constraints:
Assume volume is bound by 0 to 100
Objective: max SUM [ vol_s * prob_s - cost_s ]
- The total cost of the allocation must not exceed the available budget.
- The risk level of the allocation must not exceed the maximum allowable risk level.
- The profit margin of the allocation must not fall below the minimum allowable profit margin.
Method:
Using search algorithm to find the approx. optimial allocation
Assumptions:
- The probabilities and costs of the assets are known with certainty.
- The expected return and risk level of the allocation are calculated using historical data and statistical models.
""")
demo.launch()