Der Inhalt dieses Artikels ist eine Einführung in die Elasticsearch-PHP-API. Jetzt können Freunde in Not darauf verweisen.
Elasticsearch ist derzeit verfügbar Eines der beliebtesten Big-Data-Verarbeitungs-Frameworks. Detaillierte Anweisungen finden Sie auf Baidu usw.
In den folgenden Artikeln wird die Abkürzung es als repräsentativ für Elasticsearch verwendet
es verfügt über die offizielle PHP-API-Schnittstelle, die von Github oder Composer heruntergeladen werden kann.
$params = [ 'index' => 'user_index', //索引名（相当于mysql的数据库）
'body' => [ 'mappings' => [ 'normal_type' => [ //类型名（相当于mysql的表）
'_all'=>[ // 是否开启所有字段的检索
'enabled' => 'false'
], 'properties' => [ //文档类型设置（相当于mysql的数据类型）
'uid' => [ 'type' => 'integer' // 字段类型为整型
], 'username' => [ 'type' => 'keyword' // 字段类型为关键字,如果需要全文检索,则修改为text,注意keyword字段为整体查询,不能作为模糊搜索
], 'platform' => [ 'type' => 'keyword'
], 'mobile' => [ 'type' => 'integer'
], 'sex' => [ 'type' => 'integer'
], 'source' => [ 'type' => 'keyword'
], 'province' => [ 'type' => 'keyword'
], 'city' => [ 'type' => 'keyword'
], 'tag' => [ 'properties' => [ 'tagName' =>[ 'type' => 'text'
], 'tagWeight' => [ 'type' => 'integer',
]
]
],
]
]
]
]
];
$data = $client->indices()->create($params);Der einfache Index wird erstellt die neu erstellten Indexinformationen.
$params = [ 'index' => 'user_index', 'client' => [ 'ignore' => 404
]
];
$res = $client->indices()->getSettings($params);//获取库索引设置信息Zurückgegeben Die Ergebnisse lauten wie folgt:
array ( 'user_index' =>
array ( 'settings' =>
array ( 'index' =>
array ( 'creation_date' => '1498116455327', 'number_of_shards' => '5', 'number_of_replicas' => '1', 'uuid' => '8pkONoI7RAuw5HjnFa4UaQ', 'version' =>
array ( 'created' => '5020299',
), 'provided_name' => 'user_index',
),
),
),
)Schnittstelle: $client->indices()->getMapping
$params = [ 'index' => 'user_index', 'client' => [ 'ignore' => 404
]
];
$res = $client->indices()->getMapping($params); //获取mapping信息Die zurückgegebenen Ergebnisse lauten wie folgt:
array ( 'user_index' =>
array ( 'mappings' =>
array ( 'normal_type' =>
array ( '_all' =>
array ( 'enabled' => false,
), 'properties' =>
array ( 'city' =>
array ( 'type' => 'keyword',
), 'mobile' =>
array ( 'type' => 'integer',
), 'platform' =>
array ( 'type' => 'keyword',
), 'province' =>
array ( 'type' => 'keyword',
), 'sex' =>
array ( 'type' => 'integer',
), 'source' =>
array ( 'type' => 'keyword',
), 'uid' =>
array ( 'type' => 'integer',
), 'username' =>
array ( 'type' => 'keyword',
),
),
),
),
),
)Die hier erhaltenen relevanten Informationen sind, dass die soeben erstellten Indizes dynamisch geändert und zugehörige Informationen hinzugefügt werden können .
Hinweis: Bereits festgelegte Feldtypen können nicht geändert werden!!
Schnittstelle: $client-> ;indices()->putMapping();
$params = [ 'index' => 'user_index', //索引名（相当于mysql的数据库）
'type' => 'normal_type', 'body' => [ 'normal_type' => [ 'properties' =>[ 'tag' =>[ 'type' => 'text'
]
]
]
]
];
$client->indices()->putMapping($params);Schnittstelle: $ client->indices( )->delete($params);
$params = [ 'index' => 'user_index', //索引名（相当于mysql的数据库）
];Einzelne Dateneinfügung
Schnittstelle: $client->index()
$params = [ 'index' => 'my_index', 'type' => 'my_type', 'id' => 'my_id', // 不填则es会自动生成唯一的id
'body' => [ 'testField' => 'abc']
];
$response = $client->index($params);Batch-Daten einfügen
Schnittstelle: $client->bulk();
foreach($userList as $value){
$params['body'][] = [ 'index' => [ '_index' => 'user_index', '_type' => 'normal_type', '_id' =>$value['uid']
]
];
$params['body'][] = [ 'uid' => $value['uid'], 'username' => $value['username'], 'platform' => $value['platform'], 'mobile' => $value['mobile'], 'province' => $value['province'], 'city' => $value['city'], 'sex' => $value['gender '], 'source'=>'xxx'
];
}
$responses = $client->bulk($params);ps: Beim Einfügen in eine Schleife müssen Sie bei der Verwendung einer großen Datenmenge auf das Problem achten, dass der Speicher von PHP das Limit überschreitet (Es ist nicht klar, welcher Teil dieses Frameworks den Speicher danach nicht freigibt der Vorgang)
Einzelne Datensuche, aber Sie müssen die ID kennen
Schnittstelle: $client->get()
$params = [ 'index' => 'my_index', 'type' => 'my_type', 'id' => 'my_id' // es 自动生成/自己录入的]; $response = $client->get($params);
Stapelsuche
Schnittstelle: $client->search()
$params = [
'index' => 'my_index', //['my_index1', 'my_index2'],可以通过这种形式进行跨库查询
'type' => 'my_type',//['my_type1', 'my_type2'],
'body' => [
'query' => [
'match' => [ // 搜索条件
'age' => '24' , 'tag.tagName' =>'tag' // 如果字段存储的是object.
//这里搜索必须要这样才能搜索出结果.
]
],
'from' => '0', // 分页
'size' => '200' // 每页数量
'sort' => [ // 排序
'age' => 'desc' //对age字段进行降序排序
]
]
];
$res = $client->search($params);Die zurückgegebenen Daten lauten ungefähr wie folgt:
array (size=4) 'took' => int 2
'timed_out' => boolean false
'_shards' =>
array (size=3) 'total' => int 5
'successful' => int 5
'failed' => int 0
'hits' => // 搜索到数据
array (size=3) 'total' => int 2
'max_score' => float 1
'hits' => // 具体数据包
array (size=1) 0 =>
array (size=5)
...Viele Male, die Sie benötigen zu verwenden und/oder Abfragen wie MySQL und ES-Suche können ebenfalls durchgeführt werden.
Zu diesem Zeitpunkt werden wir den Kombinationsfilter von es verwenden
https://www.elastic.co/guide/cn/elasticsearch/guide/current/combining-filters.html Das offizielle Dokument lautet wie folgt
Das Folgende ist ein getestetes Beispiel
{ "index": "xxx_index",
"type": "normal_type",
"body": { "size": 20,
"from": 0,
"query": { "bool": { "must": [
{ "match": { "tag.tagName": "xxxx"
}
}
]
}
},
"sort": { "uid": "desc"
}
}
}Hinweis: Es gibt eine bestimmte Cache-Aktualisierungszeit, wenn Daten gelöscht werden, und sie können weiterhin durchsucht werden es wird nicht aktualisiert.
Schnittstelle: $client->delete();
$param = [ 'index' => 'my_index', 'type' => 'my_type', 'id' => 'my_id'
];
$ret = $this->client->delete($param);Die zurückgegebenen Daten lauten wie folgt:
array (size=7) 'found' => boolean true
'_index' => string 'user_index' (length=10) '_type' => string 'normal_type' (length=11) '_id' => string 'AVzh_QnIZvcaH3gE7MvE' (length=20) '_version' => int 2
'result' => string 'deleted' (length=7) '_shards' =>
array (size=3) 'total' => int 2
'successful' => int 1
'failed' => int 0Schnittstelle: $client->update()
$params = [
'index' => 'my_index',
'type' => 'my_type',
'id' => '3416a75f4cea9109507cacd8e2f2aefc',
'body' => [
'doc' => [ // 必须带上这个.表示是文档操作
'age' => 150
]
]
];
$res = $client->update($params);Return Ergebnisse
array (size=6) '_index' => string 'user_index' (length=10) '_type' => string 'normal_type' (length=11) '_id' => string 'AVzh_QnIZvcaH3gE7Mw5' (length=20) '_version' => int 2
'result' => string 'updated' (length=7) '_shards' =>
array (size=3) 'total' => int 2
'successful' => int 1 // 当数据没有发生变化时这里是为0
'failed' => int 0Hinweis: Unterschiedliche Indizes Beim Hochladen von Daten müssen Sie auf die Art der Felder achten Dies führt dazu, dass der Import fehlschlägt.
Diese Schnittstelle kann nicht in PHPAPI ausgeführt werden und ist als Datensatz vorhanden >
Schnittstelle: POST _reindexPOST _reindex
{ "source": { "index": "user_profile"
}, "dest": { "index": "user_prfile_v1"
}, "script": { "inline": " ctx._source.tag=params.new_tags", "params": { "new_tags":{ "tagName":null, "tagWeight":0
}
}
}
}Link:
https ://www.jianshu.com /p/a2837f487de6
Verwandte Empfehlungen:
php-Methode zum Aufrufen der Schnittstellen-API
Über die Organisation des Vue-Projekt-API-bezogenen Codes
Das obige ist der detaillierte Inhalt vonEinführung in die Elasticsearch-PHP-API. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!
So öffnen Sie eine PHP-Datei
So entfernen Sie die ersten paar Elemente eines Arrays in PHP
Was tun, wenn die PHP-Deserialisierung fehlschlägt?
So verbinden Sie PHP mit der MSSQL-Datenbank
So verbinden Sie PHP mit der MSSQL-Datenbank
Fensterhandle-Methode abrufen
So laden Sie HTML hoch
So lösen Sie verstümmelte Zeichen in PHP
![[Web-Frontend] Node.js-Schnellstart](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
