Import JSON raw data to ElasticSearch using Python in one line of commands
Project description
json-py-es
==========
|Build Status| |GitHub release| |PyPI| |GitHub license|
Alexander Liu
- To import raw JSON data files to ElasticSearch in one line of
commands
Installation
~~~~~~~~~~~~
- ``pip install jsonpyes``
In the past we import data in this way. Too many jobs by hands...
|before image|
Using ElasticSearch Bulk API to import this data, sometimes ES only
recognizes data in its API way.
But now let ``json-py-es`` glue them all.
jsonpyes
--------
- |user interface|
Instructions:
^^^^^^^^^^^^^
::
There are 3 proccesses of importing raw JSON data to ElasticSearch
1. Only validating raw JSON data
2. Without validating ,just import data to ElasticSearch
3. After validating successfully, then import data to ElasticSearch
1. Only validating
''''''''''''''''''
- ``jsonpyes --data raw_data.json --check``
- If the json data file is valid: |json valid|
- If the json data file is invalid: |json invalid|
2. Only importing without validating
''''''''''''''''''''''''''''''''''''
- Notice: If the raw JSON data file is invalid, ElasticSearch will not
import it.
- ``jsonpyes --data raw_data.json --bulk http://localhost:9200 --import --index myindex2 --type mytype2``
- Or enable multi-threads
``jsonpyes --data raw_data.json --bulk http://localhost:9200 --import --index myindex2 --type mytype2 --thread 8``
|no threads|
- ``jsonpyes`` supports multi-threads when importing data to
elasticsearch
- No multi-threads
.. figure:: https://raw.githubusercontent.com/xros/jsonpyes/master/static/snapshot237.png
:alt: benchmarks
benchmarks
- With 8 threads and ``jsonpyes`` cuts files into pieces, then
destributes to workers fairly
.. figure:: https://raw.githubusercontent.com/xros/jsonpyes/master/static/snapshot235.png
:alt: use helpers.bulk API with multi-threads
use helpers.bulk API with multi-threads
As you can see these two containers have same docs loaded, if we use
***--thread 8*** it could be several times faster, usually 5 to 10
times faster. That really depends on your computer/server resources.
This was tested on a 4GB RAM / 2.4Ghz intel i5 Linux x64 laptop
system.
- And it works. |it works|
3. Both validating and importing
''''''''''''''''''''''''''''''''
- ``jsonpyes --data raw_data.json --bulk http://localhost:9200 --import --index myindex1 --type mytype1 --check``
|validating and importing|
- And it works. |the results|
Happy hacking!
''''''''''''''
.. |Build Status| image:: https://travis-ci.org/xros/jsonpyes.svg?branch=master
:target: https://travis-ci.org/xros/jsonpyes
.. |GitHub release| image:: https://img.shields.io/github/release/xros/jsonpyes.svg
:target: https://github.com/xros/jsonpyes/releases
.. |PyPI| image:: https://img.shields.io/pypi/dm/jsonpyes.svg
:target: https://pypi.python.org/pypi/jsonpyes
.. |GitHub license| image:: https://img.shields.io/github/license/xros/jsonpyes.svg
:target: https://github.com/xros/jsonpyes/blob/master/LICENSE
.. |before image| image:: https://raw.githubusercontent.com/xros/jsonpyes/master/static/snapshot106.jpg
.. |user interface| image:: https://raw.githubusercontent.com/xros/jsonpyes/master/static/snapshot236.png
.. |json valid| image:: https://raw.githubusercontent.com/xros/jsonpyes/master/static/snapshot98.jpg
.. |json invalid| image:: https://raw.githubusercontent.com/xros/jsonpyes/master/static/snapshot99.jpg
.. |no threads| image:: https://raw.githubusercontent.com/xros/jsonpyes/master/static/snapshot102.jpg
.. |it works| image:: https://raw.githubusercontent.com/xros/jsonpyes/master/static/snapshot105.jpg
.. |validating and importing| image:: https://raw.githubusercontent.com/xros/jsonpyes/master/static/snapshot135.png
.. |the results| image:: https://raw.githubusercontent.com/xros/jsonpyes/master/static/snapshot101.jpg
==========
|Build Status| |GitHub release| |PyPI| |GitHub license|
Alexander Liu
- To import raw JSON data files to ElasticSearch in one line of
commands
Installation
~~~~~~~~~~~~
- ``pip install jsonpyes``
In the past we import data in this way. Too many jobs by hands...
|before image|
Using ElasticSearch Bulk API to import this data, sometimes ES only
recognizes data in its API way.
But now let ``json-py-es`` glue them all.
jsonpyes
--------
- |user interface|
Instructions:
^^^^^^^^^^^^^
::
There are 3 proccesses of importing raw JSON data to ElasticSearch
1. Only validating raw JSON data
2. Without validating ,just import data to ElasticSearch
3. After validating successfully, then import data to ElasticSearch
1. Only validating
''''''''''''''''''
- ``jsonpyes --data raw_data.json --check``
- If the json data file is valid: |json valid|
- If the json data file is invalid: |json invalid|
2. Only importing without validating
''''''''''''''''''''''''''''''''''''
- Notice: If the raw JSON data file is invalid, ElasticSearch will not
import it.
- ``jsonpyes --data raw_data.json --bulk http://localhost:9200 --import --index myindex2 --type mytype2``
- Or enable multi-threads
``jsonpyes --data raw_data.json --bulk http://localhost:9200 --import --index myindex2 --type mytype2 --thread 8``
|no threads|
- ``jsonpyes`` supports multi-threads when importing data to
elasticsearch
- No multi-threads
.. figure:: https://raw.githubusercontent.com/xros/jsonpyes/master/static/snapshot237.png
:alt: benchmarks
benchmarks
- With 8 threads and ``jsonpyes`` cuts files into pieces, then
destributes to workers fairly
.. figure:: https://raw.githubusercontent.com/xros/jsonpyes/master/static/snapshot235.png
:alt: use helpers.bulk API with multi-threads
use helpers.bulk API with multi-threads
As you can see these two containers have same docs loaded, if we use
***--thread 8*** it could be several times faster, usually 5 to 10
times faster. That really depends on your computer/server resources.
This was tested on a 4GB RAM / 2.4Ghz intel i5 Linux x64 laptop
system.
- And it works. |it works|
3. Both validating and importing
''''''''''''''''''''''''''''''''
- ``jsonpyes --data raw_data.json --bulk http://localhost:9200 --import --index myindex1 --type mytype1 --check``
|validating and importing|
- And it works. |the results|
Happy hacking!
''''''''''''''
.. |Build Status| image:: https://travis-ci.org/xros/jsonpyes.svg?branch=master
:target: https://travis-ci.org/xros/jsonpyes
.. |GitHub release| image:: https://img.shields.io/github/release/xros/jsonpyes.svg
:target: https://github.com/xros/jsonpyes/releases
.. |PyPI| image:: https://img.shields.io/pypi/dm/jsonpyes.svg
:target: https://pypi.python.org/pypi/jsonpyes
.. |GitHub license| image:: https://img.shields.io/github/license/xros/jsonpyes.svg
:target: https://github.com/xros/jsonpyes/blob/master/LICENSE
.. |before image| image:: https://raw.githubusercontent.com/xros/jsonpyes/master/static/snapshot106.jpg
.. |user interface| image:: https://raw.githubusercontent.com/xros/jsonpyes/master/static/snapshot236.png
.. |json valid| image:: https://raw.githubusercontent.com/xros/jsonpyes/master/static/snapshot98.jpg
.. |json invalid| image:: https://raw.githubusercontent.com/xros/jsonpyes/master/static/snapshot99.jpg
.. |no threads| image:: https://raw.githubusercontent.com/xros/jsonpyes/master/static/snapshot102.jpg
.. |it works| image:: https://raw.githubusercontent.com/xros/jsonpyes/master/static/snapshot105.jpg
.. |validating and importing| image:: https://raw.githubusercontent.com/xros/jsonpyes/master/static/snapshot135.png
.. |the results| image:: https://raw.githubusercontent.com/xros/jsonpyes/master/static/snapshot101.jpg
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
jsonpyes-1.2.25.tar.gz
(8.9 kB
view details)
File details
Details for the file jsonpyes-1.2.25.tar.gz
.
File metadata
- Download URL: jsonpyes-1.2.25.tar.gz
- Upload date:
- Size: 8.9 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | 1ff0a5b6eca29f1a6b04b4b0732c9c5f5aa7c169f78b03e047c4b81915f55a42 |
|
MD5 | f4e17ab5ff1b7445473b688110c5057b |
|
BLAKE2b-256 | f0c689c5ad45f8e7d0a1c0b10f94d41a41f89354bfc9465f18d6d7ca5e01fbf1 |