去年底,在大伙的基金即将成为韭菜基的时候,写过一篇《ChivesFunds韭菜基中的战斗基》用FastAPI和Prometheus获取基金数据最后由Grafana绘图的文章。
现在看上去一切又归于平静的时候,来谈谈如何将基金数据写入到InfluxDB时序数据库中。之前已经有获取基金数据的代码,这里直接在原来的基础上做扩展将数据写入InfluxDB数据库。
同样,“投资有风险,入市需谨慎”。本文旨在通过influxdb-client库学习如何将监控指标(基金数据)写入到InfluxDB数据库中并用Grafana绘制图表。
Step1.Python将数据写入InfluxDB
InfluxDB1.x和2.0之间的差别比较大,本例采用InfluxDB2.0版本,它自带有一个包含Settings、Dashboards、Tasks、Alerts等功能的web后台。可以从后台Load-Data中的Sources获取到Python的ClientLibraries示例代码。
示例代码如下:
#1.InstallPackagepipinstallinfluxdb-client#2.InitializetheClientfromdatetimeimportdatetimefrominfluxdb_clientimportInfluxDBClientfrominfluxdb_client.client.write_apiimportSYNCHRONOUS#YoucangenerateaTokenfromthe"TokensTab"intheUItoken="saRFB0QI7a_gLwU7gT1CHcqVOP4jLjCazbNdHXbDmkFHe_4GfCrtkv-gmNU3YGMCFjZFxdZX2mggrUu6UZg=="org="InfluxDB"bucket="chivesfunds"client=InfluxDBClient(url="