未提供项目说明
db-ops的Python项目详细描述
sqlite3和InfluxDB数据库的Python类助手。在
SQHelper（SqLite3数据库）
示例：创建、读取和删除只处理数据帧的表。在
fromdbops.sqhelperimportSQHelperimportpandasaspd>>>table_name='temperature'>>>df=pd.DataFrame({"timestamp":[1587222785,1587222786],'celsius':[23.3,23.9]})>>>db='myDatabase.sql3'>>>database=SQHelper(db)# The dataframe column names are used for the table's column names. # All dataframe entries are automatically inserted.>>>database.create_table(table_name,df)['timestamp','celsius']# Add some more entries to the database, in this case duplicates of the above entry are made.>>>database.insert(table_name,df)True# Read the content back into a dataframe>>>database.table_to_df(table_name)celsiustimestamp034.21587222785123.31587222785223.91587222786323.31587222785423.91587222786# Remove the table from the database>>>database.remove_table(table_name);True
示例：创建一个表，添加一个条目并将其作为Pandas dataframe返回。在
^{pr2}$使用help（SQHelper）获取更多详细信息。在
流入Db
fromdbops.imfluxhelperimportInfluxHelper# Create a class instance for a single database>>>database=InfluxHelper('database_name')# Check the database is connected to OK>>>database.exists()True# Add a new measurement to the database as a dictionary>>>data={'timestamp':1585848415,'temperature':23.3,'humidity':12.2,'room':'kitchen','house':'home'}>>>measurement='Environment'>>>fields=['temperature','humidity']>>>tags=['room','house']>>>database.insert(measurement,data,field_keys=fields,tag_keys=tags,use_timestamp=True)True# Add multiple measurements as a Pandas DataFrame>>>data=[{'timestamp':1585848415,'temperature':23.3,'humidity':12.2,'room':'kitchen','house':'home'},{'timestamp':1585848416,'temperature':22.1,'humidity':13.4,'room':'bedroom','house':'home'}]>>>df=pd.DataFrame(data)>>>measurement='Household'>>>fields=['temperature','humidity']>>>tags=['room','house']>>>database.insert(measurement,df,field_keys=fields,tag_keys=tags,use_timestamp=use_time)True# Get all the measurements in the database>>>database.get_measurement_names()['Environment','Household']# Get the last time based entry in a table>>>last_time_entry=database.get_last_time_entry('Household','humidity','room','bedroom',as_unix=True)>>>last_time_entry['last']13.4>>>last_time_entry['time']1585848416
使用帮助（InfluxHelper）获取更多详细信息。在
版本历史记录
0.1.0：
- 增加了流入数据库的接口
- 添加了一些时间戳转换实用程序
- 改进的文档
- 项目
标签：
欢迎加入QQ群-->： 979659372
