2017-09-18 27 views
0

InfluxDBとPythonの相互作用に関する次の問題があります。Windows InfluxDBとAWS InfluxDBとの相互作用

InfluxDBはWindows 7マシンにインストールされています。また、AWS ubuntuマシンのドッカーコンテナにInfluxDBがインストールされています。 InfluxDBポートをAWSマシンからローカルのWindowsマシンに転送しました。

はその後、私は次のようにInfluxDB-Sの両方に接続しようとしたPythonのinfluxdbライブラリ使用:次に

client_aws = influxdb.InfluxDBClient('localhost', 8087, '', '', 'aws_db') 
client_local = influxdb.InfluxDBClient('localhost', 8086, '', '', 'local_db') 

を、私はちょうど私のローカルマシンにAWS-マシンからデータを書きたかったです。

query = 'select field_name from test_aws' 
rs = client_aws.query(query, params={"epoch": "us"}) 
points = list(rs.get_points(measurement="test_aws")) 
db_body = [ { "measurement": "test_local", 
       "time": query_time, 
       "fields": { field_name: points[0].get("field_name") } } ] 
client_local.write_points(db_body) 

はその後、私は私の地元のInfluxDBをチェックして、クエリのない測定「test_local」が、実行がないことを検出し

select field_name from test_local 

は必要なデータを返します。さらに、ローカルのInfluxDBでは存在しないため、test_localの測定を削除することはできません。

お願いします。私のデータはどこに保存されていますか?クエリは実行されますが、測定はありません。

答えて

0

クエリは実行できますが、データは返しません。

ターゲットデータベースがローカルホストマシンに存在することを確認してから、そのデータベースにデータを挿入する必要があります。

db_localにデータを挿入してデータベースが存在することを確認する前にclient.create_database('local_db')に電話をかけてください。