From 03495d8d3614e5bc5309003a435315f92ddd41b2 Mon Sep 17 00:00:00 2001 From: JimMoen Date: Mon, 19 Sep 2022 16:53:15 +0800 Subject: [PATCH] fix: influxdb server string support scheme prefix --- lib-ee/emqx_ee_connector/src/emqx_ee_connector_influxdb.erl | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/lib-ee/emqx_ee_connector/src/emqx_ee_connector_influxdb.erl b/lib-ee/emqx_ee_connector/src/emqx_ee_connector_influxdb.erl index 2024ba8ce..3f86792ff 100644 --- a/lib-ee/emqx_ee_connector/src/emqx_ee_connector_influxdb.erl +++ b/lib-ee/emqx_ee_connector/src/emqx_ee_connector_influxdb.erl @@ -485,8 +485,12 @@ log_error_points(InstId, Errs) -> %% =================================================================== %% typereflt funcs --spec to_server_raw(string()) -> +-spec to_server_raw(string() | binary()) -> {string(), pos_integer()}. +to_server_raw(<<"http://", Server/binary>>) -> + emqx_connector_schema_lib:parse_server(Server, ?INFLUXDB_HOST_OPTIONS); +to_server_raw(<<"https://", Server/binary>>) -> + emqx_connector_schema_lib:parse_server(Server, ?INFLUXDB_HOST_OPTIONS); to_server_raw(Server) -> emqx_connector_schema_lib:parse_server(Server, ?INFLUXDB_HOST_OPTIONS).