除了Python，还有多种编程语言可实现PostgreSQL数据同步到Elasticsearch，具体如下： - **Java**：Java具有强大的生态系统和广泛的应用场景，可借助Elasticsearch的Java客户端库，如Elasticsearch High-Level REST Client或Transport Client，结合JDBC连接PostgreSQL数据库，通过编写代码实现数据同步。以下是一个简单示例： ```java import org.apache.http.HttpHost; import org.elasticsearch.action.index.IndexRequest; import org.elasticsearch.action.index.IndexResponse; import org.elasticsearch.client.RequestOptions; import org.elasticsearch.client.RestClient; import org.elasticsearch.client.RestHighLevelClient; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.Statement; import java.util.HashMap; import java.util.Map; public class PostgreSQLToElasticsearch { public static void main(String[] args) { try (RestHighLevelClient client = new RestHighLevelClient( RestClient.builder(new HttpHost("localhost", 9200, "http"))); Connection connection = DriverManager.getConnection("jdbc:postgresql://localhost:5432/your_database", "your_user", "your_password"); Statement statement = connection.createStatement()) { ResultSet resultSet = statement.executeQuery("SELECT * FROM your_table"); while (resultSet.next()) { Map<String, Object> jsonMap = new HashMap<>(); jsonMap.put("column1", resultSet.getString("column1")); jsonMap.put("column2", resultSet.getString("column2")); IndexRequest indexRequest = new IndexRequest("your_index") .source(jsonMap); IndexResponse indexResponse = client.index(indexRequest, RequestOptions.DEFAULT); } } catch (Exception e) { e.printStackTrace(); } } } ``` - **Go**：Go语言以其高效的性能和简洁的语法受到开发者青睐。可以使用Elasticsearch的Go客户端库，如`olivere/elastic`，结合Go的数据库驱动`lib/pq`连接PostgreSQL，实现数据同步。示例代码如下： ```go package main import ( "database/sql" "fmt" "github.com/olivere/elastic" _ "github.com/lib/pq" ) func main() { client, err := elastic.NewClient(elastic.SetURL("http://localhost:9200")) if err != nil { fmt.Println(err) return } db, err := sql.Open("postgres", "user=your_user password=your_password dbname=your_database sslmode=disable") if err != nil { fmt.Println(err) return } defer db.Close() rows, err := db.Query("SELECT * FROM your_table") if err != nil { fmt.Println(err) return } defer rows.Close() for rows.Next() { var column1, column2 string err := rows.Scan(&column1, &column2) if err != nil { fmt.Println(err) continue } doc := map[string]interface{}{ "column1": column1, "column2": column2, } _, err = client.Index(). Index("your_index"). BodyJson(doc). Do(nil) if err != nil { fmt.Println(err) } } } ``` - **Ruby**：Ruby语言简洁灵活，可使用`elasticsearch-ruby`库连接Elasticsearch，`pg`库连接PostgreSQL，实现数据同步。示例代码如下： ```ruby require 'pg' require 'elasticsearch' client = Elasticsearch::Client.new log: true conn = PG.connect( dbname: 'your_database', user: 'your_user', password: 'your_password' ) results = conn.exec("SELECT * FROM your_table") results.each do |row| client.index( index: 'your_index', body: { column1: row['column1'], column2: row['column2'] } ) end ```