1 Star 0 Fork 0

jx0913/stock

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
克隆/下载
transfer_data_es.py 703 Bytes
一键复制 编辑 原始数据 按行查看 历史
Rocky Chen 提交于 2019-07-15 18:29 . update
# -*-coding=utf-8-*-
# @Time : 2019/7/12 18:41
# @File : transfer_data_es.py
from setting import get_mysql_conn
from elasticsearch import Elasticsearch
es = Elasticsearch('10.18.6.102:9200')
conn = get_mysql_conn('db_stock','local')
cursor = conn.cursor()
query_cmd = 'select * from tb_cnstock'
cursor.execute(query_cmd)
ret = cursor.fetchall()
for item in ret:
# print(item)
date = item[0]
title = item[1]
url = item[2]
content = item[3]
keyword = item[4]
body = {'Title':title,'ULR':url,'keyword':keyword,'content':content,'Date':date}
try:
es.index(index='cnstock',doc_type='doc',body=body)
except Exception as e:
print(e)
print(url)
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/jx0913/stock.git
git@gitee.com:jx0913/stock.git
jx0913
stock
stock
master

搜索帮助

0d507c66 1850385 C8b1a773 1850385