从PostgreSQL同步数据到Elasticsearch

from pprint import pprint
from pg_to_es import PgToEs
 
# 初始化PgToEs对象
pg_to_es = PgToEs(
    host='localhost',
    port=5432,
    user='your_username',
    password='your_password',
    database='your_database',
    index_name='your_index_name',
    doc_type='your_doc_type',
    id_field='your_id_field',
    es_host='localhost',
    es_port=9200,
    query="""
        SELECT id, column1, column2
        FROM your_table
        WHERE your_condition
    """,
    update_by="your_condition_to_update"
)
 
# 执行同步操作
pg_to_es.sync()
 
# 打印同步结果
pprint(pg_to_es.result)

这个代码实例展示了如何初始化PgToEs对象，并执行从PostgreSQL到Elasticsearch的数据同步操作。需要注意的是，这里的代码假设了pg_to_es.py文件已经定义了PgToEs类，并且该类有一个sync方法和一个result属性。同时，用户需要根据自己的数据库和Elasticsearch配置信息填写相应的参数。