使用python的弹性搜索导入错误

Question

以下是json变量

jsonout = [{"city": "Springfield", "id": 1, "name": "Moes Tavern"}, {"city": "Springfield", "id": 2, "name": "Springfield Power Plant"}, {"city": "Fountain Lakes", "id": 3, "name": "Kath and Kim Pty Ltd"}]

下面的命令用于导入json变量

es.bulk((es.index_op(doc, id=doc('id')) for doc in jsonout), index='dbmysql', doc_type='person')

以下是错误

---------------------------------------------------------------------------
TypeError                                 Traceback (most recent call last)
<ipython-input-14-10faf5c5bb89> in <module>()
      1 docs = [{'id': 2, 'name': 'Jessica Coder', 'age': 32, 'title': 'Programmer'}, {'id': 3, 'name': 'Freddy Tester', 'age': 29, 'title': 'Office Assistant'}]
----> 2 es.bulk((es.index_op(doc, id=doc('id')) for doc in jsonout), index='dbmysql', doc_type='person')

d:\nvk\USER\Anaconda2\lib\site-packages\pyelasticsearch\client.pyc in decorate(*args, **kwargs)
     91                 elif k in convertible_args:
     92                     query_params[k] = kwargs.pop(k)
---> 93             return func(*args, query_params=query_params, **kwargs)
     94         return decorate
     95     return decorator

d:\nvk\USER\Anaconda2\lib\site-packages\pyelasticsearch\client.pyc in bulk(self, actions, index, doc_type, query_params)
    445         response = self.send_request('POST',
    446                                      [index, doc_type, '_bulk'],
--> 447                                      body='\n'.join(actions) + '\n',
    448                                      query_params=query_params)
    449 

<ipython-input-14-10faf5c5bb89> in <genexpr>((doc,))
      1 docs = [{'id': 2, 'name': 'Jessica Coder', 'age': 32, 'title': 'Programmer'}, {'id': 3, 'name': 'Freddy Tester', 'age': 29, 'title': 'Office Assistant'}]
----> 2 es.bulk((es.index_op(doc, id=doc('id')) for doc in jsonout), index='dbmysql', doc_type='person')

TypeError: 'str' object is not callable

Answer 1

终于找到了解决办法。

我们可以使用json.loads将str对象转换为json对象。

json.loads(jsonout)

Answer 2

doc很可能是不可调用的字符串。通常，jsonout听起来不像应该有函数。

Answer 3

您在问题中遗漏了一些东西--在错误示例中，您有以下代码：

1 docs = [{'id': 2, 'name': 'Jessica Coder', ...}, {...}]
2 es.bulk((es.index_op(doc, id=doc('id')) for doc in jsonout), index='dbmysql', doc_type='person')

在第1行中有docs变量，在第2行中有jsonout，如果将docs变量而不是jsonout放入第二行，您应该会得到一个类似于'dict' object is not callable的错误，因为您有doc('id') (而不是doc['id'])，doc是一本字典。

因此，我怀疑实际的jsonout变量值也有问题--它可能是一个字符串列表，而不是字典列表。