Skip to content

Instantly share code, notes, and snippets.

@xamox
Created October 18, 2016 22:09
Show Gist options
  • Star 9 You must be signed in to star a gist
  • Fork 2 You must be signed in to fork a gist
  • Save xamox/bfc4c610fd449debb3aa341863145bea to your computer and use it in GitHub Desktop.
Save xamox/bfc4c610fd449debb3aa341863145bea to your computer and use it in GitHub Desktop.
Move data from Mongo to Elasticsearch
'''
Tested with:
Mongo 3.0.12
pymongo 3.3.0
Elasticsearch 2.1.2
Kibana 4.3.3
elasticsearch python 2.1.0
'''
DATABASE = 'imo' #This will be the index you need to select in Kibana, it is also the database to use in mongo to pull data from
from pymongo import MongoClient
from elasticsearch import Elasticsearch
from elasticsearch.helpers import bulk, parallel_bulk
from collections import deque
from tqdm import tqdm
import time
client = Elasticsearch()
mgclient = MongoClient()
db = mgclient[DATABASE]
col = db['sslog']
# Pull from mongo and dump into ES using bulk API
actions = []
for data in tqdm(col.find(), total=col.count()):
data.pop('_id')
action = {
"_index": DATABASE,
"_type": "sslog",
"_source": data
}
actions.append(action)
# Dump x number of objects at a time
if len(actions) >= 100:
deque(parallel_bulk(client, actions), maxlen=0)
actions = []
time.sleep(.01)
@mikelauw
Copy link

how to use code from import data above?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment