Я пытаюсь использовать Elasticsearch Bulk API с жадностью, но я не знаю, какой правильный формат для тела.
Когда я делаю это с curl, у меня нет никаких проблем.
curl -X POST "http://localhost:9200/hakuna/matata/_bulk" -H 'Content-Type: application/json' -d'
{"index": {}}
{"title": "Abc", "category": "Alphabet", "tags": ["premier", "alphabet"], "duration": 40}
{"index": {}}
{"title": "Def", "category": "Alphabet", "tags": ["second", "alphabet"], "duration": 50}
{"index": {}}
{"title": "Ghi", "category": "Alphabet", "tags": ["troisieme", "alphabet"], "duration": 60}
'
Когда я делаю это с жрет, я всегда получаю эту ошибку
Client error: `POST http://localhost:9200/hakuna/matata/_bulk` resul
ted in a `400 Bad Request` response:
{"error":{"root_cause":[{"type":"action_request_validation_exception","reas
on":"Validation Failed: 1: no requests added; (truncated...)
Это код php
$data = [
json_encode(['index' => []]),
json_encode(['title' => 'Abc', 'category' => 'Alphabet', 'tags' => ['premier', 'alphabet'], 'duration' => 40]),
json_encode(['index' => []]),
json_encode(['title' => 'Def', 'category' => 'Alphabet', 'tags' => ['second', 'alphabet'], 'duration' => 50]),
json_encode(['index' => []]),
json_encode(['title' => 'Ghi', 'category' => 'Alphabet', 'tags' => ['troisieme', 'alphabet'], 'duration' => 60]),
];
$data = join("\n", $data);
$response = $client->post('hakuna/matata/_bulk', [
'headers' => ['Content-Type' => 'application/json'],
'json' => $data,
]);
Я пытался с обычным массивом без json_encode и без преобразования строки, но я всегда получаю ту же ошибку.
РЕДАКТИРОВАТЬ: окончательный рабочий код
$data = [
json_encode(['index' => []], JSON_FORCE_OBJECT),
json_encode(['title' => 'Abc', 'category' => 'Alphabet', 'tags' => ['premier', 'alphabet'], 'duration' => 40]),
json_encode(['index' => []], JSON_FORCE_OBJECT),
json_encode(['title' => 'Def', 'category' => 'Alphabet', 'tags' => ['second', 'alphabet'], 'duration' => 50]),
json_encode(['index' => []], JSON_FORCE_OBJECT),
json_encode(['title' => 'Ghi', 'category' => 'Alphabet', 'tags' => ['troisieme', 'alphabet'], 'duration' => 60]),
];
$data = join("\n", $data);
$response = $client->post('hakuna/matata/_bulk', [
'headers' => ['Content-Type' => 'application/json'],
'body' => $data."\n",
]);
Вы на правильном пути, хорошие усилия до сих пор!
Все, что вам нужно сделать сейчас, это добавить символ новой строки в конце каждой строки включая последний, как это:
$data = [
json_encode(['index' => []]),
json_encode(['title' => 'Abc', 'category' => 'Alphabet', 'tags' => ['premier', 'alphabet'], 'duration' => 40]),
json_encode(['index' => []]),
json_encode(['title' => 'Def', 'category' => 'Alphabet', 'tags' => ['second', 'alphabet'], 'duration' => 50]),
json_encode(['index' => []]),
json_encode(['title' => 'Ghi', 'category' => 'Alphabet', 'tags' => ['troisieme', 'alphabet'], 'duration' => 60]),
];
$data = join("\n", $data);
$response = $client->post('hakuna/matata/_bulk', [
'headers' => ['Content-Type' => 'application/json'],
'body' => $data . '\n'; <--- change this line
]);
Других решений пока нет …