PowerShell JSONをElasticSearchに投稿

Question

PowerShell経由でElasticSearchにデータをプッシュしようとしています。私はデータをJSONに変換してから、Invoke-WebRequestとInvoke-RestMethodの両方を試していますが、不正なデータやコンテンツタイプのエラーはサポートされていません。私はそれが私のためにそれを作成すると信じて私はインデックスを作成していない。私が間違っている/欠けているものに支援することができ

誰ですか？

例コード：

$data = @() 
$CustomObject = [pscustomobject]@{ 
     SqlInstance = "myserver1" 
     Database = "mydb" 
     Schema = "versioning" 
     Name = "DataVersionHistory" 
     IndexSpaceUsed = 0 
     DataSpaceUsed = 0 
     RowCount = 0 
     }; 
$data += $CustomObject; 
$CustomObject = [pscustomobject]@{ 
     SqlInstance = "myserver1" 
     Database = "mydb" 
     Schema = "versioning" 
     Name = "VersionHistory" 
     IndexSpaceUsed = 10 
     DataSpaceUsed = 25 
     RowCount = 3000 
     }; 
$data += $CustomObject; 
$myJson = ConvertTo-Json -InputObject $data ; 
Invoke-RestMethod -Uri http://localhost:9200/myindex/mytype/_bulk?pretty ` 
-Method POST -Body $myJson -ContentType "application/json" 

Answer 1

バルク要求は実際のJSONではありません。あなたは、配列$dataに含まれるオブジェクトのコレクションを持っている。この時点で

curl -XPOST 'localhost:9200/_bulk?pretty' -H 'Content-Type: application/json' -d' 
{ "index" : { "_index" : "test", "_type" : "type1", "_id" : "1" } } 
{ "field1" : "value1" } 
{ "delete" : { "_index" : "test", "_type" : "type1", "_id" : "2" } } 
{ "create" : { "_index" : "test", "_type" : "type1", "_id" : "3" } } 
{ "field1" : "value3" } 
{ "update" : {"_id" : "1", "_type" : "type1", "_index" : "test"} } 
{ "doc" : {"field2" : "value2"} } 
' 

Answer 2

$data = @() 
    $CustomObject = [pscustomobject]@{ 
     SqlInstance = "myserver1" 
     Database  = "mydb" 
     Schema   = "versioning" 
     Name   = "DataVersionHistory" 
     IndexSpaceUsed = 0 
     DataSpaceUsed = 0 
     RowCount  = 0 
    }; 
    $data += $CustomObject; 
    $CustomObject = [pscustomobject]@{ 
     SqlInstance = "myserver1" 
     Database  = "mydb" 
     Schema   = "versioning" 
     Name   = "VersionHistory" 
     IndexSpaceUsed = 10 
     DataSpaceUsed = 25 
     RowCount  = 3000 
    }; 
    $data += $CustomObject 

：あなたは、次の表記を使用する必要があります。

注：バルクAPI用のJSONデータの最後の行が改行文字\ nので終わらなければなりません。だから私はhere-stringを使って各json要素に改行文字\nを追加しています。

また、私はかわいいプリントを削除しました。これはバルクAPIでうまくいくことです。

doc_as_upsertは、docが新規として追加しない場合は、それだけを残して存在している場合ことを保証します。

$json_col = @() 
$data | 
    ForEach-Object { 
     #convert object to json 
     $json_element = @{doc = $_; doc_as_upsert = $true}  
      | ConvertTo-Json -Depth 1 -Compress 

     #construt here string with literal \n 
     $json_col += @" 

$json_element\n 

"@ 
    } 
Invoke-RestMethod -Method Post -Uri "http://localhost:9200/myindex/mytype/_bulk?" -Body $json_col -ErrorAction Stop