英文:
akka-http elasticsearch {"error":"no handler found for uri [https://localhost:9200/myindex/_bulk] and method [POST]"}
问题
你遇到的问题可能是由于缺少正确的请求处理程序或URI路径导致的。请检查以下几点：
-
确保 Elasticsearch 8.7.0 正在运行，而且能够通过
https://localhost:9200访问。 -
确保你的 Elasticsearch 8.7.0 支持
_bulk操作。有时，Elasticsearch 的配置可能需要启用_bulk操作，否则默认情况下可能不支持。 -
检查你的 Akka HTTP 请求是否正确。确保 URI 路径是正确的，并且请求的方法是
POST。
如果以上检查都没有问题，仍然遇到问题，那么可能需要更详细的 Elasticsearch 和 Akka HTTP 配置信息，以便更好地帮助你解决问题。
英文:
So, I am using elasticsearch 8.7.0.
I create index 'my index':
curl --insecure --user "elastic:password" -X PUT "https://localhost:9200/myindex"
I can add JSON documents manually to elasticsearch 8.7.0 using curl
curl --insecure --user "elastic:password" -X POST "https://localhost:9200/myindex/_bulk" -H 'Content-Type: application/json' -d'{"some": "json"}'
but when I try to do it programmatically with akka-http in Scala 3 using the code below:
@maindef main(args: String*): Unit = {val records = Seq("""{ "index":{ "_index" : "myindex", "_id" : "1" } }|{"title":"title1"}""".stripMargin,"""{ "index":{ "_index" : "myindex", "_id" : "2" } }|{"title":"title2"}""".stripMargin,"""{ "index":{ "_index" : "myindex", "_id" : "3" } }|{"title":"title3"}""".stripMargin,"""{ "index":{ "_index" : "myindex", "_id" : "4" } }|{"title":"title4"}""".stripMargin)implicit val system: ActorSystem = ActorSystem("elastic")implicit val ec: ExecutionContextExecutor = system.dispatcherval trustfulSslContext: SSLContext = {// https://github.com/raboof/akka-http-connect-without-checking-cert/blob/0ca55a06afb83b587f592dd97358970502f7b834/Main.scalaobject NoCheckX509TrustManager extends X509TrustManager {override def checkClientTrusted(chain: Array[X509Certificate], authType: String): Unit = ()override def checkServerTrusted(chain: Array[X509Certificate], authType: String): Unit = ()override def getAcceptedIssuers: Array[X509Certificate] = Array[X509Certificate]()}val context: SSLContext = SSLContext.getInstance("TLS")context.init(Array[KeyManager](), Array(NoCheckX509TrustManager), new SecureRandom())context}Source.fromIterator[String]( () => records.iterator ).grouped(2).map(_.mkString("\n")).map { payload =>val entity = HttpEntity(ContentTypes.`application/json`, payload)val request = HttpRequest(HttpMethods.POST,uri = Uri("https://localhost:9200/myindex/_bulk"),headers = Seq(headers.Authorization(BasicHttpCredentials("elastic", "password"))),entity = entity)println(s"request: $request")request}.via(Http().outgoingConnectionHttps(host = "localhost", port = 9200, connectionContext = ConnectionContext.httpsClient(trustfulSslContext))).map(response => {println(s"response: ${response.entity.toStrict(1 second).map(_.data.utf8String)}")response}).toMat(Sink.ignore)(Keep.none).run()}
I get the following output
request: HttpRequest(HttpMethod(POST),https://localhost:9200/myindex/_bulk,List(Authorization),HttpEntity.Strict(application/json,137 bytes total),HttpProtocol(HTTP/1.1))response: FulfilledFuture({"error":"no handler found for uri [https://localhost:9200/myindex/_bulk] and method [POST]"})request: HttpRequest(HttpMethod(POST),https://localhost:9200/myindex/_bulk,List(Authorization),HttpEntity.Strict(application/json,137 bytes total),HttpProtocol(HTTP/1.1))response: FulfilledFuture({"error":"no handler found for uri [https://localhost:9200/myindex/_bulk] and method [POST]"})
What am I missing?
答案1
得分: 0
明显地，URI 只能包含路径部分，而不是完整的 URL。
将 Uri("https://localhost:9200/myindex/_bulk") 替换为 Uri("/myindex/_bulk") 可以解决这个问题。
此外，负载必须以 \n 结尾，所以我还不得不将 .map(_.mkString("\n")) 替换为 .map(_.mkString("", "\n", "\n")) 以使其正常工作。
英文:
Apparently, the URI can only contain the path, not the full URL.
Replacing Uri("https://localhost:9200/myindex/_bulk") by Uri("/myindex/_bulk") in the HttpRequest fixes the problem.
Additionally, the payload must end by \n so, I also had to replace .map(_.mkString("\n")) by .map(_.mkString("", "\n", "\n")) to get it to work.
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库，让每个人都能够通过互相帮助和分享经验来进步。
评论