连接和访问从InfluxDB（自托管服务器）到Jupyter Notebook的数据

Question

我一直在尝试通过jupyter笔记本访问InfluxDB自托管数据。 参考链接： https：///www.influxdata。 com/blog/streaming time series-with-jupyter and-influxdb/ 。 从influxdb进口infuxdbclient 从DateTime Import DateTime 从influxdb_client导入OS Import

Import infuxdbclient，Point，WritePrecision 来自influxdb_client.client.write_api导入同步 client = influxdbclient（url =“”，token =令牌，org = org，bucket = bucket = bucket，host = influxdb_host）

代码已成功执行到此处，我一直在尝试在Ref链接中建议的下一步，并且已经获得了一个。尽管我成功地导入了HVPLOT，但流的导入错误。

def source_data(auto_refresh: int, query: str, sink: Stream):
    rx \
        .interval(period=timedelta(seconds=auto_refresh)) \
        .pipe(ops.map(lambda start: f'from(bucket: "my-bucket") '
                                    f'|> range(start: -{auto_refresh}s, stop: now()) '
                                    f'{query}')) \
        .pipe(ops.map(lambda query: client.query_api().query_data_frame(query, data_frame_index=['_time']))) \
        .pipe(ops.map(lambda data_frame: data_frame.drop(columns=['result', 'table']))) \
        .subscribe(observer=lambda data_frame: sink.emit(data_frame), on_error=lambda error: print(error))
    pass

这是将自托管数据提取到jupyter笔记本电脑的正确方法吗？还是我一直在研究错误的参考文献。

请提出任何参考链接，以从涌入DB提取自启示的数据到jupyter笔记本。

谢谢， 迪皮卡