|
| 1 | +from boltzmann_wealth_model.model import BoltzmannWealthModel |
| 2 | + |
| 3 | +import streamlit as st |
| 4 | + |
| 5 | +import time |
| 6 | + |
| 7 | +import pandas as pd |
| 8 | + |
| 9 | +import altair as alt |
| 10 | + |
| 11 | + |
| 12 | +model = st.title("Boltzman Wealth Model") |
| 13 | +num_agents = st.slider( |
| 14 | + "Choose how many agents to include in the model", |
| 15 | + min_value=1, |
| 16 | + max_value=100, |
| 17 | + value=50, |
| 18 | +) |
| 19 | +num_ticks = st.slider( |
| 20 | + "Select number of Simulation Runs", min_value=1, max_value=100, value=50 |
| 21 | +) |
| 22 | +height = st.slider("Select Grid Height", min_value=10, max_value=100, step=10, value=15) |
| 23 | +width = st.slider("Select Grid Width", min_value=10, max_value=100, step=10, value=20) |
| 24 | +model = BoltzmannWealthModel(num_agents, height, width) |
| 25 | + |
| 26 | + |
| 27 | +status_text = st.empty() |
| 28 | +run = st.button("Run Simulation") |
| 29 | + |
| 30 | + |
| 31 | +if run: |
| 32 | + tick = time.time() |
| 33 | + step = 0 |
| 34 | + # init grid |
| 35 | + df_grid = pd.DataFrame() |
| 36 | + df_gini = pd.DataFrame({"step": [0], "gini": [-1]}) |
| 37 | + for x in range(width): |
| 38 | + for y in range(height): |
| 39 | + df_grid = pd.concat( |
| 40 | + [df_grid, pd.DataFrame({"x": [x], "y": [y], "agent_count": 0})], |
| 41 | + ignore_index=True, |
| 42 | + ) |
| 43 | + |
| 44 | + heatmap = ( |
| 45 | + alt.Chart(df_grid) |
| 46 | + .mark_point(size=100) |
| 47 | + .encode(x="x", y="y", color=alt.Color("agent_count")) |
| 48 | + .interactive() |
| 49 | + .properties(width=800, height=600) |
| 50 | + ) |
| 51 | + |
| 52 | + line = ( |
| 53 | + alt.Chart(df_gini) |
| 54 | + .mark_line(point=True) |
| 55 | + .encode(x="step", y="gini") |
| 56 | + .properties(width=800, height=600) |
| 57 | + ) |
| 58 | + |
| 59 | + # init progress bar |
| 60 | + my_bar = st.progress(0, text="Simulation Progress") # progress |
| 61 | + placeholder = st.empty() |
| 62 | + st.subheader("Agent Grid") |
| 63 | + chart = st.altair_chart(heatmap) |
| 64 | + st.subheader("Gini Values") |
| 65 | + line_chart = st.altair_chart(line) |
| 66 | + |
| 67 | + color_scale = alt.Scale( |
| 68 | + domain=[0, 1, 2, 3, 4], range=["red", "cyan", "white", "white", "blue"] |
| 69 | + ) |
| 70 | + for i in range(num_ticks): |
| 71 | + model.step() |
| 72 | + my_bar.progress((i / num_ticks), text="Simulation progress") |
| 73 | + placeholder.text("Step = %d" % i) |
| 74 | + for cell in model.grid.coord_iter(): |
| 75 | + cell_content, x, y = cell |
| 76 | + agent_count = len(cell_content) |
| 77 | + selected_row = df_grid[(df_grid["x"] == x) & (df_grid["y"] == y)] |
| 78 | + df_grid.loc[ |
| 79 | + selected_row.index, "agent_count" |
| 80 | + ] = agent_count # random.choice([1,2]) |
| 81 | + |
| 82 | + df_gini = pd.concat( |
| 83 | + [ |
| 84 | + df_gini, |
| 85 | + pd.DataFrame( |
| 86 | + {"step": [i], "gini": [model.datacollector.model_vars["Gini"][i]]} |
| 87 | + ), |
| 88 | + ] |
| 89 | + ) |
| 90 | + # st.table(df_grid) |
| 91 | + heatmap = ( |
| 92 | + alt.Chart(df_grid) |
| 93 | + .mark_circle(size=100) |
| 94 | + .encode(x="x", y="y", color=alt.Color("agent_count", scale=color_scale)) |
| 95 | + .interactive() |
| 96 | + .properties(width=800, height=600) |
| 97 | + ) |
| 98 | + chart.altair_chart(heatmap) |
| 99 | + |
| 100 | + line = ( |
| 101 | + alt.Chart(df_gini) |
| 102 | + .mark_line(point=True) |
| 103 | + .encode(x="step", y="gini") |
| 104 | + .properties(width=800, height=600) |
| 105 | + ) |
| 106 | + line_chart.altair_chart(line) |
| 107 | + |
| 108 | + time.sleep(0.01) |
| 109 | + |
| 110 | + tock = time.time() |
| 111 | + st.success(f"Simulation completed in {tock - tick:.2f} secs") |
| 112 | + |
| 113 | + # st.subheader('Agent Grid') |
| 114 | + # fig = px.imshow(agent_counts,labels={'color':'Agent Count'}) |
| 115 | + # st.plotly_chart(fig) |
| 116 | + # st.subheader('Gini value over sim ticks (Plotly)') |
| 117 | + # chart = st.line_chart(model.datacollector.model_vars['Gini']) |
0 commit comments