sis-extras

概览

sis-extras软件包提供了一组Python实用工具，旨在帮助您开发美观、性能良好的streamlit-in-snowflake应用程序。

目前，此软件包包括用于管理数据库连接（connection.py）和创建交互式数据面板（formatting.py）的模块。

安装

要安装sis-extras，您可以使用pip

pip install sis-extras

模块

connection.py

本模块处理与Snowflake数据库的连接，提供管理会话和直接执行SQL查询的功能，并将结果以Pandas DataFrame格式返回。

关键函数

• SnowparkConnection：管理Snowflake数据库连接。
• get_data_frame_from_raw_sql：执行SQL查询并将结果作为Pandas DataFrame返回。
• get_pandas_df：将Snowpark DataFrame转换为Pandas DataFrame。
• join_cached：提供了一种缓存机制，用于连接两个Snowpark DataFrame。

formatting.py

本模块有助于使用Streamlit、Altair和Plotly可视化数据，重点在于创建可以显示数据、图表和SQL查询的交互式面板。

关键函数

• tile：在Streamlit中创建可以显示图表、数据预览、SQL查询和描述的面板。
• tile_ctx：tile的上下文管理器版本，可在面板内进行更灵活的内容管理。
• altair_time_series：使用Altair生成时间序列图表，旨在处理特定的格式化和工具提示要求。

使用示例

使用SnowparkConnection

from sis_extras.connection import get_table, get_data_frame_from_raw_sql, get_pandas_df

# Use Snowpark API

table = get_table("your_table").limit(10)

table_pd = get_pandas_df(table)

st.write(table_pd)

# Use SQL

table_pd = get_data_frame_from_raw_sql("SELECT * FROM your_table")

st.write(table_pd)

创建数据面板

from sis_extras.formatting import tile
import pandas as pd
import altair as alt

# Sample DataFrame

data = pd.DataFrame({
    'x': range(10),
    'y': range(10)
})

# Sample Chart

chart = alt.Chart(data).mark_line().encode(
    x='x',
    y='y'
)

# Create a tile with data and chart

tile(data, "Sample Tile", chart=chart, sql="SELECT x, y FROM your_table")