0

IAMで管理されているElasticSearchドメインに接続しようとしています。要求を作成して署名しましたが、すべてGETメソッドで正常に動作しますが、POSTメソッドでは400 Bad RequestAWS ElasticSearchでの不正リクエスト

これは明らかにペイロードと関係があります。ペイロードの空文字列( "")を提供すると、それはうまく機能しますが、それ以外の場合は不正な要求が発生します。

私には何が欠けていますか?

val url = s"https://$host/TEST/article/_search" 
val serviceName = "es" 
val regionName = "us-east-1" 


val request = new DefaultRequest(serviceName) 

val payload = 
    """{"1":"1"}""".trim 
val payloadBytes = payload.getBytes(StandardCharsets.UTF_8) 
val payloadStream = new ByteArrayInputStream(payloadBytes) 
request.setContent(payloadStream) 

val endpointUri = URI.create(url) 
request.setEndpoint(endpointUri) 
request.setHttpMethod(HttpMethodName.POST) 

val credProvider = new EnvironmentVariableCredentialsProvider 
val credentials = credProvider.getCredentials 

val signer = new AWS4Signer 

signer.setRegionName(regionName) 
signer.setServiceName(serviceName) 

signer.sign(request, credentials) 

val context = new ExecutionContext(true) 

val clientConfiguration = new ClientConfiguration() 
val client = new AmazonHttpClient(clientConfiguration) 

val rh = new MyHttpResponseHandler 
val eh = new MyErrorHandler 

val response = 
    client.execute(request, rh , eh, context); 

答えて

0

ノート:あなたはこの問題に実行する場合、応答の実際の内容を検査し、それはインデックスとクエリの間のミスマッチの結果である可能性があります。

私の問題は、使用していた特定のクエリが指定されたインデックスに不適切であり、結果が400となったことです。

関連する問題