Einführung in die Elasticsearch-PHP-API

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.

1. Index erstellen ($client->indices()->create())

      $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.

2. Indexinformationen abrufen

2.1 Indexinformationen abrufen ($client->indices()->getSettings())

     $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',
        ),
      ),
    ),
 )

2.2 Mapping-Informationen abrufen

• 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 .

2.3 Zuordnungsinformationen ändern/hinzufügen

• 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);

2.4 Index löschen

• Schnittstelle: $ client->indices( )->delete($params);

        $params = [            'index' => 'user_index',  //索引名（相当于mysql的数据库）
        ];

3 es Hinzufügen, Löschen, Ändern und Abfragen

3.1 Daten hinzufügen

• 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)

3.2 Daten suchen

• 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"
        }
    }
}

3.3 Daten löschen

• 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 0

3.4 Daten aktualisieren

• Schnittstelle: $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 0

4. Daten zwischen verschiedenen Indizes umkehren

• Hinweis: 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 _reindex

POST _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
      }
    }
  }
}

Autor: Tang Minzheng

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!