【发布时间】:2019-04-12 20:10:15
【问题描述】:
如何使用 influxdb-python 客户端编写这段代码?
SELECT column1 INTO 'db2.retention_policy2.measurement2.' FROM 'db1.retention_policy1.measurement1.' WHERE 时间 > '2019-01-01';"
我知道您可以创建两个连接,甚至只使用一个连接来查询数据库。
一种方法可能是这样的:
- 从 db1 获取所需数据
- 使用 connection.switch_database("db2") 切换数据库
- 那么有哪些方法可以将数据推送到 db2 中?
谢谢。
【问题讨论】:
-
我没有使用
influxdb的经验,但你不能简单地使用完全限定标识符吗?db.schmea.table?如果您尝试过,为什么它不起作用?你有错误吗?如果是这样,你得到什么错误?什么是完整的 Traceback? -
我假设这样的事情可以工作:
client.query('SELECT column1 INTO 'db2.retention_policy2.measurement2 FROM "db1.retention_policy1.measurement1" where time > '2019-01-01)给定:client.get_list_database()返回两者:[{'name': 'db1'}, {'name': 'db2'}] -
我只需要授予两个数据库的读/写权限。
标签: python influxdb influxdb-python