InfluxDB DataFrameClient KeyError：83

Question

私は、ある時間範囲のデータを流入させるために必要なプロセス用のやや自動化されたクエリビルダを構築しています。その目的のために、時間をかけてフィルタリングする必要があります。つまり、クエリにエポックミリ秒の文字列が必要です。このコードは、次のエラーをスローします。

import pandas as pd 

ts = pd.Timestamp(pd.Timestamp('now', tz='US/Pacific').date(), tz='US/Pacific') 
ts_str = str(int(ts.value/(10 ** 6))) 
query_str = 'SELECT * FROM "table"."measurement" WHERE time <= ' + \ 
      ts_str + 'ms LIMIT 10' 
json_payload = client.query(query_str) 
print(json_payload) 

とスタックトレース：

Traceback (most recent call last): 
    File "my_code.py", line 31, in query 
    return self.client.query(query) 
    File "/usr/local/lib/python2.7/site-packages/influxdb/_dataframe_client.py", line 138, in query 
    results = super(DataFrameClient, self).query(query, database=database) 
    File "/usr/local/lib/python2.7/site-packages/influxdb/client.py", line 339, in query 
    expected_response_code=expected_response_code 
    File "/usr/local/lib/python2.7/site-packages/influxdb/client.py", line 239, in request 
    timeout=self._timeout 
    File "/usr/local/lib/python2.7/site-packages/requests/sessions.py", line 474, in request 
    prep = self.prepare_request(req) 
    File "/usr/local/lib/python2.7/site-packages/requests/sessions.py", line 407, in prepare_request 
    hooks=merge_hooks(request.hooks, self.hooks), 
    File "/usr/local/lib/python2.7/site-packages/requests/models.py", line 302, in prepare 
    self.prepare_url(url, params) 
    File "/usr/local/lib/python2.7/site-packages/requests/models.py", line 426, in prepare_url 
    enc_params = self._encode_params(params) 
    File "/usr/local/lib/python2.7/site-packages/requests/models.py", line 104, in _encode_params 
    return urlencode(result, doseq=True) 
    File "/usr/local/Cellar/python/2.7.11/Frameworks/Python.framework/Versions/2.7/lib/python2.7/urllib.py", line 1353, in urlencode 
    v = quote_plus(v) 
    File "/usr/local/Cellar/python/2.7.11/Frameworks/Python.framework/Versions/2.7/lib/python2.7/urllib.py", line 1308, in quote_plus 
    s = quote(s, safe + ' ') 
    File "/usr/local/Cellar/python/2.7.11/Frameworks/Python.framework/Versions/2.7/lib/python2.7/urllib.py", line 1303, in quote 
    return ''.join(map(quoter, s)) 
KeyError: 83 

Answer 1

流入がts_str作品のUnicodeのSTRをスワップアウトユニコード、単一引用符、二重引用符などについて非常にうるさいです。前と後のquery_strを印刷すると同じように見えますが、フードの種類は重要です。

import pandas as pd 

ts = pd.Timestamp(pd.Timestamp('now', tz='US/Pacific').date(), tz='US/Pacific') 
ts_str = unicode(int(ts.value/(10 ** 6))) 
query_str = 'SELECT * FROM "table"."measurement" WHERE time <= ' + \ 
      ts_str + 'ms LIMIT 10' 
json_payload = client.query(query_str) 
print(json_payload)