Elasticsearch

https://seatunnel.apache.org/docs/2.3.3/connector-v2/source/Elasticsearch

Elasticsearch 源连接器

描述

用于从 Elasticsearch 中读取数据。

支持版本 >= 2.x 和 "
c_array = "array"
c_string = string
c_boolean = boolean
c_tinyint = tinyint
c_smallint = smallint
c_int = int
c_bigint = bigint
c_float = float
c_double = double
c_decimal = "decimal(2, 1)"
c_bytes = bytes
c_date = date
c_timestamp = timestamp
}
}
query = {"range":{"firstPacket":{"gte":1669225429990,"lte":1669225429990}}}
}

## SSL (Disable certificates validation)

source {
Elasticsearch {
hosts = ["https://localhost:9200"]
username = "elastic"
password = "elasticsearch"

    tls_verify_certificate = false
}

}

## SSL (Disable hostname validation)

source {
Elasticsearch {
hosts = ["https://localhost:9200"]
username = "elastic"
password = "elasticsearch"

    tls_verify_hostname = false
}

}

## SSL (Enable certificates validation)

source {
Elasticsearch {
hosts = ["https://localhost:9200"]
username = "elastic"
password = "elasticsearch"

    tls_keystore_path = "${your elasticsearch home}/config/certs/http.p12"
    tls_keystore_password = "${your password}"
}

}

# 参考资料

https://seatunnel.apache.org/docs/2.3.3/concept/JobEnvConfig