FilesExpand file tree

 master

/

scroll.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

30 lines (22 loc) · 627 Bytes

 master

/

scroll.py

Copy path

Top

File metadata and controls

• Code
• Blame

30 lines (22 loc) · 627 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

from elasticsearch import Elasticsearch

es = Elasticsearch()

res = es.search(

index = 'users',

doc_type = 'doc',

scroll = '20m',

size = 500,

body = {"query":{"match_all":{}}}

)

for search_doc in res['hits']['hits']:

print(search_doc['_source'])

sid = res['_scroll_id']

size = res['hits']['total']['value']

# Start scrolling

while (size > 0):

print(size)

print("--------------------------------------------")

res = es.scroll(scroll_id = sid, scroll = '20m')

sid = res['_scroll_id']

size = len(res['hits']['hits'])

for doc in res['hits']['hits']:

print(doc['_source'])