JRICKL opened this issue 7 years ago · 2 comments
RT,方便贴一下参考
@JRICKL 还请查看es分支下的代码。
class ElasticSearchPipeline(object): # 将伯乐在线数据写入到es中 def process_item(self, item, spider): # 将item转换为es数据。 item.save_to_es() return item
此处注释忘记改了。应该改为通用的es存入。
具体的三个网站的存入方法都写在具体items中的save_to_es()方法中。
thank you!