のようなエラスティック検索ライブラリを使用しようとしていますがpyelasticsearch
、elasticsearch
データフレームを渡すことができるメソッドが得られず、そのメソッドはデータフレームデータをエラスティック検索にロードします。
私はこのコードを試しています:
for i,df in enumerate(csvfile):
print (i)
records=df.where(pd.notnull(df), None).T.to_dict()
list_records=[records[it] for it in records]
print(list_records)
try :
es.bulk_index("call_demo_data1","tweet",list_records)
except :
print ("error!, skiping some tweets sorry")
pass
csvfile は、すべてのデータが存在するデータフレームです。しかし、次のエラーが発生しています
'str' object has no attribute 'where'
コメントでおすすめを使用しました
問題が解決したので、一括読み込み中にこのエラーが発生します
上記の方法を使用してデータのエラスティック検索をロードしていますが、問題に直面していたので、以前に投稿した質問へのリンクを次に示します
これが私が今使っているコードです:
records= csvfile.T.to_dict()
list_records=[records[it] for it in records]
#print(list_records)
es.bulk_index("call_demo_data1","tweet",list_records)
私が得ているエラーは次のとおりです。
too many values to unpack (expected 2)
このエラーは、一括インデックス作成中に発生します。上記のコードの csvfile はデータ フレームです。このライブラリを使用していますpyelasticsearch