初始化数据流

Surge（ surge）是一个开源的 Python 库，用于分析和处理数据流，它提供了一套模块化的工具，包括数据流、算法、日志和配置部分，以下是一个使用指南，帮助你熟悉和应用 surge。

安装 surge

• 安装命令：

  pip install surge

创建数据流

数据流负责读取和处理来自数据源的数据，以下是一个示例，使用Kaggle的weather数据集：

from surge import DataStream
ds = DataStream("https://raw.githubusercontent.com/Kaggle/lightning-frames/master/Weather/Daily.csv")

读取数据

数据流支持本地文件、网络数据和数据库读取：

# 读取本地文件
ds.read("weather.csv")
# 读取网络数据
ds.read("https://raw.githubusercontent.com/lsar/air-p red-ocean/master/221125/airdata_221125127_22112513_221125132_221125133_221125134_221125135_221125136_221125137_221125138_221125139_22112514_221125141_221125142_221125143_221125144_221125145_221125146_221125147_221125148_221125149_22112515_221125151_221125152_221125153_221125154_221125155_221125156_221125157_221125158_221125159_22112516_221125161_221125162_221125163_221125164_221125165_221125166_221125167_221125168_221125169_22112517_221125171_221125172_221125173_221125174_221125175_221125176_221125177_221125178_221125179_22112518_221125181_221125182_221125183_221125184_221125185_221125186_221125187_221125188_221125189_22112519_221125191_221125192_221125193_221125194_221125195_221125196_221125197_221125198_221125199_2211252_22112521_22112522_22112523_22112524_22112525_22112526_22112527_22112528_22112529_22112521_221125211_221125212_221125213_221125214_221125215_221125216_221125217_221125218_221125219_22112522_221125221_221125222_221125223_221125224_221125225_221125226_221125227_221125228_221125229_22112523_221125231_221125232_221125233_221125234_221125235_221125236_221125237_221125238_221125239_22112524_221125241_221125242_221125243_221125244_221125245_221125246_2211252