将MariaDB中的多个表同步到Elasticsearch 7.5

PUT /my_index
{
  "settings": {
    "number_of_shards": 1,
    "number_of_replicas": 1
  },
  "mappings": {
    "properties": {
      "id": {
        "type": "integer"
      },
      "name": {
        "type": "text"
      },
      "description": {
        "type": "text"
      }
    }
  }
}

import pymysql
from elasticsearch import Elasticsearch

# 连接到MariaDB
conn = pymysql.connect(host='localhost', user='username', password='password', db='database')
cursor = conn.cursor()

# 连接到Elasticsearch
es = Elasticsearch()

# 查询MariaDB中的数据
cursor.execute("SELECT * FROM table1")
results = cursor.fetchall()

# 将数据同步到Elasticsearch
for row in results:
    doc = {
        'id': row[0],
        'name': row[1],
        'description': row[2]
    }
    es.index(index='my_index', doc_type='_doc', body=doc)

# 关闭连接
cursor.close()
conn.close()