python - pandas to_json 输出用双引号括起来，以提供给 Elasticsearch

Question

Pandas DataFrame 的 to_json 方法正确返回数据。但我无法在下一步中处理它。例如

try:
    from StringIO import StringIO
except ImportError:
    from io import StringIO

myst="""
20-01-17    pizza   90
21-01-17    pizza   120
22-01-17    pizza   239
23-01-17    pizza   200
20-01-17    fried-rice  100
21-01-17    fried-rice  120
22-01-17    fried-rice  110
23-01-17    fried-rice  190
20-01-17    ice-cream   8
21-01-17    ice-cream   23
22-01-17    ice-cream   21
23-01-17    ice-cream   100
"""
u_cols=['date', 'product', 'sales']

myf = StringIO(myst)
import pandas as pd
df = pd.read_csv(StringIO(myst), sep='\s+', names = u_cols)

下一步是将数据导出为 JSON，以便导入到 Elasticsearch 中。

tmp=df.to_json(orient="records")
import json
json.loads(tmp)

这将返回以下(无效 JSON)输出:

[{'date': '20-01-17', 'product': 'pizza', 'sales': 90},
 {'date': '21-01-17', 'product': 'pizza', 'sales': 120},
 {'date': '22-01-17', 'product': 'pizza', 'sales': 239},
 {'date': '23-01-17', 'product': 'pizza', 'sales': 200},
 {'date': '20-01-17', 'product': 'fried-rice', 'sales': 100},
 {'date': '21-01-17', 'product': 'fried-rice', 'sales': 120},
 {'date': '22-01-17', 'product': 'fried-rice', 'sales': 110},
 {'date': '23-01-17', 'product': 'fried-rice', 'sales': 190},
 {'date': '20-01-17', 'product': 'ice-cream', 'sales': 8},
 {'date': '21-01-17', 'product': 'ice-cream', 'sales': 23},
 {'date': '22-01-17', 'product': 'ice-cream', 'sales': 21},
 {'date': '23-01-17', 'product': 'ice-cream', 'sales': 100}]

Elastic 似乎不喜欢单引号。如何在双引号中获得与上面相同的输出？

Answer 1

不确定它是否有帮助，但在代码后面添加类似的内容

from elasticsearch import Elasticsearch
from elasticsearch.helpers import bulk

es = Elasticsearch()

actions = [
     {
     '_index' : 'transactions',
     '_type' : 'content',
     '_date' : rec['date'],
     '_product' : rec['product'],
     '_sales' : rec['sales'],
     }
for rec in json.loads(tmp)
]

bulk(es, actions)

应该允许创建索引。