Spaces:
Sleeping
Sleeping
import streamlit as st | |
from azure.cosmos import CosmosClient, PartitionKey | |
import os | |
import pandas as pd | |
st.set_page_config(layout="wide") | |
# Cosmos DB configuration | |
ENDPOINT = "https://acae-afd.documents.azure.com:443/" | |
SUBSCRIPTION_ID = "003fba60-5b3f-48f4-ab36-3ed11bc40816" | |
# You'll need to set these environment variables or use Azure Key Vault | |
DATABASE_NAME = os.environ.get("COSMOS_DATABASE_NAME") | |
CONTAINER_NAME = os.environ.get("COSMOS_CONTAINER_NAME") | |
Key = os.environ.get("Key") | |
def insert_record(record): | |
try: | |
response = container.create_item(body=record) | |
return True, response | |
except Exception as e: | |
return False, str(e) | |
def call_stored_procedure(record): | |
try: | |
response = container.scripts.execute_stored_procedure( | |
sproc="processPrompt", | |
params=[record], | |
partition_key=record['id'] | |
) | |
return True, response | |
except Exception as e: | |
error_message = f"Error type: {type(e).__name__}\nError message: {str(e)}" | |
if hasattr(e, 'sub_status'): | |
error_message += f"\nSub-status: {e.sub_status}" | |
if hasattr(e, 'response'): | |
error_message += f"\nResponse: {e.response}" | |
return False, error_message | |
def fetch_all_records(): | |
query = "SELECT * FROM c" | |
items = list(container.query_items(query=query, enable_cross_partition_query=True)) | |
return pd.DataFrame(items) | |
def delete_records(ids): | |
try: | |
for id in ids: | |
container.delete_item(item=id, partition_key=id) | |
return True, f"Successfully deleted {len(ids)} records" | |
except Exception as e: | |
return False, f"Error deleting records: {str(e)}" | |
# Streamlit app | |
st.title("π Cosmos DB Record Management") | |
# Initialize session state for selected IDs | |
if 'selected_ids' not in st.session_state: | |
st.session_state.selected_ids = set() | |
# Login section | |
if 'logged_in' not in st.session_state: | |
st.session_state.logged_in = False | |
if not st.session_state.logged_in: | |
st.subheader("π Login") | |
input_key = Key # Use the predefined Key instead of asking for user input | |
if st.button("π Login"): | |
if input_key: | |
st.session_state.primary_key = input_key | |
st.session_state.logged_in = True | |
st.rerun() | |
else: | |
st.error("Invalid key. Please check your environment variables.") | |
else: | |
# Initialize Cosmos DB client | |
client = CosmosClient(ENDPOINT, credential=st.session_state.primary_key) | |
database = client.get_database_client(DATABASE_NAME) | |
container = database.get_container_client(CONTAINER_NAME) | |
# Fetch and display all records | |
st.subheader("π All Records") | |
df = fetch_all_records() | |
# Add a checkbox column to the dataframe | |
df['select'] = df['id'].isin(st.session_state.selected_ids) | |
# Use Streamlit's data editor | |
edited_df = st.data_editor(df, key="data_editor", disabled=["id", "name", "document", "evaluationText", "evaluationScore"]) | |
# Update selected_ids based on the edited dataframe | |
selected_rows = edited_df[edited_df['select']] | |
st.session_state.selected_ids = set(selected_rows['id']) | |
# Display selected IDs with emoji checkboxes | |
if st.session_state.selected_ids: | |
st.markdown("### Selected Records:") | |
for id in st.session_state.selected_ids: | |
st.markdown(f"β {id}") | |
else: | |
st.markdown("### No Records Selected") | |
# Add delete and download buttons | |
col1, col2 = st.columns(2) | |
with col1: | |
if st.button("ποΈ Delete Selected"): | |
if st.session_state.selected_ids: | |
success, message = delete_records(list(st.session_state.selected_ids)) | |
if success: | |
st.success(message) | |
st.session_state.selected_ids.clear() # Clear the selection after successful deletion | |
else: | |
st.error(message) | |
st.rerun() | |
else: | |
st.warning("No records selected for deletion.") | |
with col2: | |
if st.download_button("π₯ Download Data", df.to_csv(index=False), "cosmos_db_data.csv", "text/csv"): | |
st.success("Data downloaded successfully!") | |
# Input fields for new record | |
st.subheader("π Enter New Record Details") | |
new_id = st.text_input("ID") | |
new_name = st.text_input("Name") | |
new_document = st.text_area("Document") | |
new_evaluation_text = st.text_area("Evaluation Text") | |
new_evaluation_score = st.number_input("Evaluation Score", min_value=0, max_value=100, step=1) | |
col1, col2 = st.columns(2) | |
# Insert Record button | |
with col1: | |
if st.button("πΎ Insert Record"): | |
record = { | |
"id": new_id, | |
"name": new_name, | |
"document": new_document, | |
"evaluationText": new_evaluation_text, | |
"evaluationScore": new_evaluation_score | |
} | |
success, response = insert_record(record) | |
if success: | |
st.success("β Record inserted successfully!") | |
st.json(response) | |
else: | |
st.error(f"β Failed to insert record: {response}") | |
st.rerun() | |
# Call Procedure button | |
with col2: | |
if st.button("π§ Call Procedure"): | |
record = { | |
"id": new_id, | |
"name": new_name, | |
"document": new_document, | |
"evaluationText": new_evaluation_text, | |
"evaluationScore": new_evaluation_score | |
} | |
success, response = call_stored_procedure(record) | |
if success: | |
st.success("β Stored procedure executed successfully!") | |
st.json(response) | |
else: | |
st.error(f"β Failed to execute stored procedure: {response}") | |
# Logout button | |
if st.button("πͺ Logout"): | |
st.session_state.logged_in = False | |
st.session_state.selected_ids.clear() # Clear selected IDs on logout | |
st.rerun() | |
# Display connection info | |
st.sidebar.subheader("π Connection Information") | |
st.sidebar.text(f"Endpoint: {ENDPOINT}") | |
st.sidebar.text(f"Subscription ID: {SUBSCRIPTION_ID}") | |
st.sidebar.text(f"Database: {DATABASE_NAME}") | |
st.sidebar.text(f"Container: {CONTAINER_NAME}") |