python - 使用 elasticsearch 的 jupyter python notebook

Question

我在 DSX 中将 elasticsearch 与 jupyter python notebook 一起使用。当我将数据框写入对象存储时，出现错误：

ratings_df.write.format("org.elasticsearch.spark.sql").save("swift://DSConnections.spark/ratings.es")

Py4JJavaError：调用 o96.save 时发生错误。：java.lang.ClassNotFoundException：找不到数据源：org.elasticsearch.spark.sql。请在http://spark-packages.org找到包

Answer 1

您需要安装弹性搜索连接器。

import pixiedust pixiedust.installPackage("org.elasticsearch:elasticsearch-spark_2.10:2.4.4")

PixiedustManager 的参考

http://datascience.ibm.com/docs/content/analyze-data/Package-Manager.html#installfrommavensearch

谢谢，查尔斯。