Spaces:
Running
Running
Fix: Readme
Browse files- streamlit_app.py +0 -26
streamlit_app.py
CHANGED
|
@@ -147,39 +147,15 @@ if st.session_state.authenticated:
|
|
| 147 |
state_param = selected_state if selected_state != 'India' else None
|
| 148 |
market_param = selected_market if market_wise else None
|
| 149 |
|
| 150 |
-
# Debug: Show query parameters
|
| 151 |
-
st.write(f"π **Debug Info:**")
|
| 152 |
-
st.write(f"- State: {state_param}")
|
| 153 |
-
st.write(f"- Market: {market_param}")
|
| 154 |
-
st.write(f"- Days: {st.session_state.selected_period}")
|
| 155 |
-
st.write(f"- Current time: {datetime.now()}")
|
| 156 |
-
st.write(f"- Query start date: {datetime.now() - timedelta(days=st.session_state.selected_period)}")
|
| 157 |
-
|
| 158 |
df = get_filtered_data(collection, state_param, market_param, st.session_state.selected_period)
|
| 159 |
|
| 160 |
if not df.empty:
|
| 161 |
-
# Debug: Show raw data info
|
| 162 |
-
st.write(f"π **Raw data fetched: {len(df)} rows**")
|
| 163 |
-
st.write(f"- Date range in raw data: {df['Reported Date'].min()} to {df['Reported Date'].max()}")
|
| 164 |
-
st.write(f"- Unique dates in raw data: {df['Reported Date'].nunique()}")
|
| 165 |
-
|
| 166 |
-
# Show first few rows
|
| 167 |
-
with st.expander("View first 10 rows of raw data"):
|
| 168 |
-
st.dataframe(df.head(10))
|
| 169 |
-
|
| 170 |
# Group by date and aggregate
|
| 171 |
df_grouped = df.groupby('Reported Date', as_index=False).agg({
|
| 172 |
'Arrivals (Tonnes)': 'sum',
|
| 173 |
'Modal Price (Rs./Quintal)': 'mean'
|
| 174 |
})
|
| 175 |
|
| 176 |
-
st.write(f"π **After grouping: {len(df_grouped)} unique dates**")
|
| 177 |
-
st.write(f"π° **Price range: {df_grouped['Modal Price (Rs./Quintal)'].min():.2f} - {df_grouped['Modal Price (Rs./Quintal)'].max():.2f}**")
|
| 178 |
-
|
| 179 |
-
# Show grouped data
|
| 180 |
-
with st.expander("View grouped data (first 10 rows)"):
|
| 181 |
-
st.dataframe(df_grouped.head(10))
|
| 182 |
-
|
| 183 |
# Create complete date range and fill gaps
|
| 184 |
date_range = pd.date_range(
|
| 185 |
start=df_grouped['Reported Date'].min(),
|
|
@@ -192,8 +168,6 @@ if st.session_state.authenticated:
|
|
| 192 |
df_grouped['Arrivals (Tonnes)'] = df_grouped['Arrivals (Tonnes)'].ffill().bfill()
|
| 193 |
df_grouped['Modal Price (Rs./Quintal)'] = df_grouped['Modal Price (Rs./Quintal)'].ffill().bfill()
|
| 194 |
|
| 195 |
-
st.write(f"π **Plotting {len(df_grouped)} data points after filling date gaps**")
|
| 196 |
-
|
| 197 |
st.subheader(f"π Trends for {selected_state} ({'Market: ' + selected_market if market_wise else 'State'})")
|
| 198 |
|
| 199 |
if data_type == "Both":
|
|
|
|
| 147 |
state_param = selected_state if selected_state != 'India' else None
|
| 148 |
market_param = selected_market if market_wise else None
|
| 149 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 150 |
df = get_filtered_data(collection, state_param, market_param, st.session_state.selected_period)
|
| 151 |
|
| 152 |
if not df.empty:
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 153 |
# Group by date and aggregate
|
| 154 |
df_grouped = df.groupby('Reported Date', as_index=False).agg({
|
| 155 |
'Arrivals (Tonnes)': 'sum',
|
| 156 |
'Modal Price (Rs./Quintal)': 'mean'
|
| 157 |
})
|
| 158 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 159 |
# Create complete date range and fill gaps
|
| 160 |
date_range = pd.date_range(
|
| 161 |
start=df_grouped['Reported Date'].min(),
|
|
|
|
| 168 |
df_grouped['Arrivals (Tonnes)'] = df_grouped['Arrivals (Tonnes)'].ffill().bfill()
|
| 169 |
df_grouped['Modal Price (Rs./Quintal)'] = df_grouped['Modal Price (Rs./Quintal)'].ffill().bfill()
|
| 170 |
|
|
|
|
|
|
|
| 171 |
st.subheader(f"π Trends for {selected_state} ({'Market: ' + selected_market if market_wise else 'State'})")
|
| 172 |
|
| 173 |
if data_type == "Both":
|