Update app.py
Browse files
app.py
CHANGED
|
@@ -8,135 +8,181 @@ import streamlit as st
|
|
| 8 |
import tensorflow as tf
|
| 9 |
from nltk.corpus import stopwords
|
| 10 |
from nltk.tokenize import word_tokenize
|
| 11 |
-
from tensorflow.keras.preprocessing.text import Tokenizer
|
| 12 |
from tensorflow.keras.preprocessing.sequence import pad_sequences
|
|
|
|
|
|
|
|
|
|
| 13 |
|
|
|
|
|
|
|
|
|
|
| 14 |
|
| 15 |
-
#
|
| 16 |
-
#
|
| 17 |
-
# -----------------------------
|
| 18 |
-
load_model = tf.keras.models.load_model # IMPORTANT
|
| 19 |
|
|
|
|
|
|
|
| 20 |
|
| 21 |
-
#
|
| 22 |
-
# NLTK Requirements
|
| 23 |
-
# -----------------------------
|
| 24 |
-
# Custom NLTK directory
|
| 25 |
NLTK_DIR = os.path.join(os.getcwd(), "nltk_data")
|
| 26 |
os.makedirs(NLTK_DIR, exist_ok=True)
|
| 27 |
nltk.data.path.append(NLTK_DIR)
|
| 28 |
|
| 29 |
-
# Download
|
| 30 |
try:
|
| 31 |
nltk.data.find('tokenizers/punkt')
|
| 32 |
except LookupError:
|
| 33 |
nltk.download('punkt', download_dir=NLTK_DIR)
|
| 34 |
|
| 35 |
-
# Download stopwords if missing
|
| 36 |
try:
|
| 37 |
nltk.data.find('corpora/stopwords')
|
| 38 |
except LookupError:
|
| 39 |
nltk.download('stopwords', download_dir=NLTK_DIR)
|
| 40 |
|
| 41 |
-
#
|
| 42 |
-
|
| 43 |
-
|
| 44 |
-
|
| 45 |
-
|
| 46 |
-
|
| 47 |
-
|
| 48 |
-
|
| 49 |
-
#
|
| 50 |
-
#
|
| 51 |
-
|
| 52 |
-
st.
|
| 53 |
-
|
| 54 |
-
|
| 55 |
-
|
| 56 |
-
|
| 57 |
-
|
| 58 |
-
|
| 59 |
-
|
| 60 |
-
#
|
| 61 |
-
|
| 62 |
-
|
| 63 |
-
|
| 64 |
-
|
| 65 |
-
|
| 66 |
-
|
| 67 |
-
|
| 68 |
-
|
| 69 |
-
with open("
|
| 70 |
-
|
| 71 |
-
|
| 72 |
-
|
| 73 |
-
mlb = pickle.load(f)
|
| 74 |
|
| 75 |
-
|
| 76 |
-
|
| 77 |
-
|
| 78 |
-
|
| 79 |
-
|
|
|
|
| 80 |
|
| 81 |
-
|
|
|
|
| 82 |
|
|
|
|
|
|
|
|
|
|
| 83 |
|
| 84 |
-
# -----------------------------
|
| 85 |
-
# Clean Text
|
| 86 |
-
# -----------------------------
|
| 87 |
def clean_text(t):
|
| 88 |
-
|
|
|
|
| 89 |
return ""
|
| 90 |
-
|
| 91 |
-
t = t.lower()
|
|
|
|
|
|
|
| 92 |
tokens = word_tokenize(t)
|
| 93 |
tokens = [w for w in tokens if w not in stop_english and len(w) > 2]
|
| 94 |
t = " ".join(tokens)
|
| 95 |
-
|
| 96 |
-
#
|
| 97 |
-
t = re.sub(r"<.*?>", " ", t)
|
| 98 |
-
t = re.sub(r"\\n", " ", t)
|
| 99 |
-
t = re.sub(r"http\S+|www\.\S+", " ", t)
|
| 100 |
-
t = re.sub(r"\S+@\S+", " ", t)
|
| 101 |
-
|
| 102 |
-
t = re.sub(r"\
|
| 103 |
-
|
|
|
|
| 104 |
return t
|
| 105 |
|
| 106 |
-
|
| 107 |
-
# -----------------------------
|
| 108 |
-
# Convert Text → Sequence
|
| 109 |
-
# -----------------------------
|
| 110 |
def convert_to_sequence(txt):
|
| 111 |
-
|
|
|
|
| 112 |
padded = pad_sequences(seq, maxlen=MAX_SEQ_LEN, padding="pre", truncating="pre")
|
| 113 |
return padded
|
| 114 |
|
|
|
|
|
|
|
|
|
|
| 115 |
|
|
|
|
|
|
|
| 116 |
|
| 117 |
-
#
|
| 118 |
-
|
| 119 |
-
|
| 120 |
-
|
| 121 |
-
|
| 122 |
-
|
| 123 |
-
cleaned = clean_text(raw_text)
|
| 124 |
-
st.write("Cleaned Text:", cleaned)
|
| 125 |
|
| 126 |
-
seq = convert_to_sequence(cleaned)
|
| 127 |
|
| 128 |
-
|
| 129 |
-
|
| 130 |
-
pred_type_probs, pred_queue_probs, pred_tags_probs = preds
|
| 131 |
|
| 132 |
-
|
| 133 |
-
|
| 134 |
-
|
|
|
|
| 135 |
|
| 136 |
-
|
| 137 |
-
|
| 138 |
-
|
| 139 |
|
| 140 |
-
|
| 141 |
-
|
| 142 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 8 |
import tensorflow as tf
|
| 9 |
from nltk.corpus import stopwords
|
| 10 |
from nltk.tokenize import word_tokenize
|
|
|
|
| 11 |
from tensorflow.keras.preprocessing.sequence import pad_sequences
|
| 12 |
+
# Note: Tokenizer import is not strictly needed here since it's loaded from file,
|
| 13 |
+
# but it was in your original code, so it is kept for completeness.
|
| 14 |
+
# from tensorflow.keras.preprocessing.text import Tokenizer
|
| 15 |
|
| 16 |
+
## -----------------------------
|
| 17 |
+
## 📦 Setup and Configuration
|
| 18 |
+
## -----------------------------
|
| 19 |
|
| 20 |
+
# Use TensorFlow's legacy loader for compatibility
|
| 21 |
+
load_model = tf.keras.models.load_model # IMPORTANT for older Streamlit/TensorFlow versions
|
|
|
|
|
|
|
| 22 |
|
| 23 |
+
# English stop words list
|
| 24 |
+
stop_english = set(stopwords.words('english'))
|
| 25 |
|
| 26 |
+
# Custom NLTK directory setup
|
|
|
|
|
|
|
|
|
|
| 27 |
NLTK_DIR = os.path.join(os.getcwd(), "nltk_data")
|
| 28 |
os.makedirs(NLTK_DIR, exist_ok=True)
|
| 29 |
nltk.data.path.append(NLTK_DIR)
|
| 30 |
|
| 31 |
+
# Download NLTK resources if missing
|
| 32 |
try:
|
| 33 |
nltk.data.find('tokenizers/punkt')
|
| 34 |
except LookupError:
|
| 35 |
nltk.download('punkt', download_dir=NLTK_DIR)
|
| 36 |
|
|
|
|
| 37 |
try:
|
| 38 |
nltk.data.find('corpora/stopwords')
|
| 39 |
except LookupError:
|
| 40 |
nltk.download('stopwords', download_dir=NLTK_DIR)
|
| 41 |
|
| 42 |
+
# Configuration must be set before Streamlit components are defined
|
| 43 |
+
st.set_page_config(
|
| 44 |
+
page_title="Ticket Classification App",
|
| 45 |
+
layout="centered",
|
| 46 |
+
initial_sidebar_state="auto"
|
| 47 |
+
)
|
| 48 |
+
|
| 49 |
+
## -----------------------------
|
| 50 |
+
## ⚙️ Load Model, Tokenizer, and Encoders
|
| 51 |
+
## -----------------------------
|
| 52 |
+
|
| 53 |
+
@st.cache_resource
|
| 54 |
+
def load_assets():
|
| 55 |
+
"""Loads all necessary machine learning assets."""
|
| 56 |
+
try:
|
| 57 |
+
# Load Model
|
| 58 |
+
model_path = "model.h5"
|
| 59 |
+
model = load_model(model_path, compile=False)
|
| 60 |
+
|
| 61 |
+
# Load Encoders
|
| 62 |
+
with open("le_type.pkl", "rb") as f:
|
| 63 |
+
le_type = pickle.load(f)
|
| 64 |
+
with open("le_queue.pkl", "rb") as f:
|
| 65 |
+
le_queue = pickle.load(f)
|
| 66 |
+
with open("mlb.pkl", "rb") as f:
|
| 67 |
+
mlb = pickle.load(f)
|
| 68 |
+
|
| 69 |
+
# Load Tokenizer
|
| 70 |
+
with open("tokenizer.pkl", "rb") as f:
|
| 71 |
+
tokenizer = pickle.load(f)
|
| 72 |
+
|
| 73 |
+
return model, le_type, le_queue, mlb, tokenizer
|
|
|
|
| 74 |
|
| 75 |
+
except FileNotFoundError as e:
|
| 76 |
+
st.error(f"Missing required file: {e.filename}. Please ensure 'model.h5', 'tokenizer.pkl', 'le_type.pkl', 'le_queue.pkl', and 'mlb.pkl' are in the same directory.")
|
| 77 |
+
st.stop()
|
| 78 |
+
except Exception as e:
|
| 79 |
+
st.error(f"An error occurred during asset loading: {e}")
|
| 80 |
+
st.stop()
|
| 81 |
|
| 82 |
+
model, le_type, le_queue, mlb, tokenizer = load_assets()
|
| 83 |
+
MAX_SEQ_LEN = 107 # MUST match training parameter
|
| 84 |
|
| 85 |
+
## -----------------------------
|
| 86 |
+
## 🧼 Text Cleaning and Preparation Functions
|
| 87 |
+
## -----------------------------
|
| 88 |
|
|
|
|
|
|
|
|
|
|
| 89 |
def clean_text(t):
|
| 90 |
+
"""Performs text cleaning including lowercasing, stop word removal, and regex cleaning."""
|
| 91 |
+
if pd.isna(t) or t is None:
|
| 92 |
return ""
|
| 93 |
+
|
| 94 |
+
t = str(t).lower()
|
| 95 |
+
|
| 96 |
+
# Tokenization and Stop Word Removal
|
| 97 |
tokens = word_tokenize(t)
|
| 98 |
tokens = [w for w in tokens if w not in stop_english and len(w) > 2]
|
| 99 |
t = " ".join(tokens)
|
| 100 |
+
|
| 101 |
+
# Regex cleaning
|
| 102 |
+
t = re.sub(r"<.*?>", " ", t) # Remove HTML tags
|
| 103 |
+
t = re.sub(r"\\n", " ", t) # Remove literal \n
|
| 104 |
+
t = re.sub(r"http\S+|www\.\S+", " ", t) # Remove URLs
|
| 105 |
+
t = re.sub(r"\S+@\S+", " ", t) # Remove emails
|
| 106 |
+
# Remove various punctuation and special characters
|
| 107 |
+
t = re.sub(r"[%\[\]_\\<\(\]#\?\'\":\)\-\;\+\!\/,>\.\n\r]", " ", t)
|
| 108 |
+
t = re.sub(r"\s+", " ", t).strip() # Collapse multiple spaces and trim
|
| 109 |
+
|
| 110 |
return t
|
| 111 |
|
|
|
|
|
|
|
|
|
|
|
|
|
| 112 |
def convert_to_sequence(txt):
|
| 113 |
+
"""Converts cleaned text to a padded sequence."""
|
| 114 |
+
seq = tokenizer.texts_to_sequences([txt]) # Tokenizer expects a list
|
| 115 |
padded = pad_sequences(seq, maxlen=MAX_SEQ_LEN, padding="pre", truncating="pre")
|
| 116 |
return padded
|
| 117 |
|
| 118 |
+
## -----------------------------
|
| 119 |
+
## 🖥️ Streamlit UI
|
| 120 |
+
## -----------------------------
|
| 121 |
|
| 122 |
+
st.title("🎫 Ticket Classification App")
|
| 123 |
+
st.markdown("Enter the subject and body of a support ticket to predict its **Type**, **Queue**, and **Tags**.")
|
| 124 |
|
| 125 |
+
# Example text display (for context/help)
|
| 126 |
+
st.subheader("Example Input")
|
| 127 |
+
st.code("""Subject: Account Disruption
|
| 128 |
+
Body: Dear Customer Support Team, I am writing to report a significant problem with the centralized account management portal...""")
|
| 129 |
+
st.markdown("---")
|
|
|
|
|
|
|
|
|
|
| 130 |
|
|
|
|
| 131 |
|
| 132 |
+
col1, col2 = st.columns(2)
|
|
|
|
|
|
|
| 133 |
|
| 134 |
+
with col1:
|
| 135 |
+
subject = st.text_input("Enter the **Subject**:", key="subject_input")
|
| 136 |
+
with col2:
|
| 137 |
+
body = st.text_area("Enter the **Body**:", key="body_input", height=100)
|
| 138 |
|
| 139 |
+
## -----------------------------
|
| 140 |
+
## 🚀 Prediction Logic
|
| 141 |
+
## -----------------------------
|
| 142 |
|
| 143 |
+
if st.button("Submit for Classification"):
|
| 144 |
+
|
| 145 |
+
if not subject and not body:
|
| 146 |
+
st.warning("Please enter some text in the Subject or Body fields to submit.")
|
| 147 |
+
else:
|
| 148 |
+
with st.spinner('Classifying ticket...'):
|
| 149 |
+
# Combine and Clean Text
|
| 150 |
+
raw_text = subject + " " + body
|
| 151 |
+
cleaned = clean_text(raw_text)
|
| 152 |
+
|
| 153 |
+
if not cleaned:
|
| 154 |
+
st.warning("The input text was empty or contained only stop words/punctuation after cleaning.")
|
| 155 |
+
else:
|
| 156 |
+
# Convert to Sequence
|
| 157 |
+
seq = convert_to_sequence(cleaned)
|
| 158 |
+
|
| 159 |
+
# Make Prediction
|
| 160 |
+
preds = model.predict(seq, verbose=0)
|
| 161 |
+
pred_type_probs, pred_queue_probs, pred_tags_probs = preds
|
| 162 |
+
|
| 163 |
+
# Decode single-label outputs
|
| 164 |
+
pred_type = le_type.inverse_transform([np.argmax(pred_type_probs)])
|
| 165 |
+
pred_queue = le_queue.inverse_transform([np.argmax(pred_queue_probs)])
|
| 166 |
+
|
| 167 |
+
# Decode multi-label outputs
|
| 168 |
+
pred_tags_binary = (pred_tags_probs >= 0.5).astype(int)
|
| 169 |
+
pred_tags = mlb.inverse_transform(pred_tags_binary)
|
| 170 |
+
|
| 171 |
+
# --- Display Results ---
|
| 172 |
+
st.success("Classification Complete!")
|
| 173 |
+
|
| 174 |
+
st.markdown("### Predicted Categories")
|
| 175 |
+
st.write(f"**Type:** `{pred_type[0]}`")
|
| 176 |
+
st.write(f"**Queue:** `{pred_queue[0]}`")
|
| 177 |
+
|
| 178 |
+
if pred_tags and pred_tags[0]:
|
| 179 |
+
st.write(f"**Tags:** `{'`, `'.join(pred_tags[0])}`")
|
| 180 |
+
else:
|
| 181 |
+
st.write("**Tags:** *No tags predicted (below threshold)*")
|
| 182 |
+
|
| 183 |
+
st.markdown("---")
|
| 184 |
+
st.markdown("### Preprocessing Details")
|
| 185 |
+
st.write("**Cleaned Text:**", cleaned)
|
| 186 |
+
# Optional: Show a preview of the probability scores for debugging
|
| 187 |
+
# st.write("Type Confidence:", np.max(pred_type_probs))
|
| 188 |
+
# st.write("Queue Confidence:", np.max(pred_queue_probs))
|