Elasticsearch-PHP API 소개-PHP 튜토리얼-php.cn

이 글은 Elasticsearch-PHP API에 대한 소개를 소개합니다. 이제 공유합니다. 도움이 필요한 친구들이 참고할 수 있습니다.

Elasticsearch는 현재 널리 사용되는 빅데이터 처리 프레임워크 중 하나입니다. Baidu 등
다음 기사에서는 es 약어를 사용하여 Elasticsearch를 나타냅니다.

es에는 공식 PHP API 인터페이스가 있으며, 이는 Github 또는 Composer에서 다운로드할 수 있습니다.

1. 인덱스 생성 ($client->indices()->create())

      $params = [                &#39;index&#39; => &#39;user_index&#39;,  //索引名（相当于mysql的数据库）
                &#39;body&#39; => [                    &#39;mappings&#39; => [                        &#39;normal_type&#39; => [ //类型名（相当于mysql的表）
                            &#39;_all&#39;=>[   //  是否开启所有字段的检索
                                &#39;enabled&#39; => &#39;false&#39;
                            ],                            &#39;properties&#39; => [ //文档类型设置（相当于mysql的数据类型）
                                &#39;uid&#39; => [                                    &#39;type&#39; => &#39;integer&#39; // 字段类型为整型
                                ],                                &#39;username&#39; => [                                    &#39;type&#39; => &#39;keyword&#39; // 字段类型为关键字,如果需要全文检索,则修改为text,注意keyword字段为整体查询,不能作为模糊搜索
                                ],                                &#39;platform&#39; => [                                    &#39;type&#39; => &#39;keyword&#39;
                                ],                                &#39;mobile&#39; => [                                    &#39;type&#39; => &#39;integer&#39;
                                ],                                &#39;sex&#39; => [                                    &#39;type&#39; => &#39;integer&#39;
                                ],                                &#39;source&#39; => [                                    &#39;type&#39; => &#39;keyword&#39;
                                ],                                &#39;province&#39; => [                                    &#39;type&#39; => &#39;keyword&#39;
                                ],                                &#39;city&#39; => [                                    &#39;type&#39; => &#39;keyword&#39;
                                ],                              &#39;tag&#39; =>   [                                &#39;properties&#39;    =>  [                                    &#39;tagName&#39;   =>[                                        &#39;type&#39; => &#39;text&#39;
                                    ],                                    &#39;tagWeight&#39;   => [                                        &#39;type&#39; => &#39;integer&#39;,
                                    ]
                                ]
                            ],
                            ]
                        ]
                    ]
                ]
            ];
            $data = $client->indices()->create($params);

로그인 후 복사

간단한 인덱스가 생성되었으니 이제 새로 생성된 인덱스 정보를 얻을 수 있습니다.

2. 인덱스 정보

2.1 인덱스 정보 가져오기($client->indices()->getSettings())

     $params = [                &#39;index&#39; => &#39;user_index&#39;,                &#39;client&#39; => [                    &#39;ignore&#39; => 404
                ]
            ];
    $res = $client->indices()->getSettings($params);//获取库索引设置信息

로그인 후 복사

반환된 결과는 다음과 같습니다.

  array (    &#39;user_index&#39; => 
    array (    &#39;settings&#39; => 
    array (      &#39;index&#39; => 
      array (        &#39;creation_date&#39; => &#39;1498116455327&#39;,        &#39;number_of_shards&#39; => &#39;5&#39;,        &#39;number_of_replicas&#39; => &#39;1&#39;,        &#39;uuid&#39; => &#39;8pkONoI7RAuw5HjnFa4UaQ&#39;,        &#39;version&#39; => 
        array (          &#39;created&#39; => &#39;5020299&#39;,
        ),        &#39;provided_name&#39; => &#39;user_index&#39;,
        ),
      ),
    ),
 )

로그인 후 복사

2.2 매핑 정보 가져오기

인터페이스: $client- >indices()-> ;getMapping

$params = [                &#39;index&#39; => &#39;user_index&#39;,                &#39;client&#39; => [                    &#39;ignore&#39; => 404
                ]
            ];
$res = $client->indices()->getMapping($params);   //获取mapping信息

로그인 후 복사

반환된 결과는 다음과 같습니다.

array (  &#39;user_index&#39; => 
  array (    &#39;mappings&#39; => 
    array (      &#39;normal_type&#39; => 
      array (        &#39;_all&#39; => 
        array (          &#39;enabled&#39; => false,
        ),        &#39;properties&#39; => 
        array (          &#39;city&#39; => 
          array (            &#39;type&#39; => &#39;keyword&#39;,
          ),          &#39;mobile&#39; => 
          array (            &#39;type&#39; => &#39;integer&#39;,
          ),          &#39;platform&#39; => 
          array (            &#39;type&#39; => &#39;keyword&#39;,
          ),          &#39;province&#39; => 
          array (            &#39;type&#39; => &#39;keyword&#39;,
          ),          &#39;sex&#39; => 
          array (            &#39;type&#39; => &#39;integer&#39;,
          ),          &#39;source&#39; => 
          array (            &#39;type&#39; => &#39;keyword&#39;,
          ),          &#39;uid&#39; => 
          array (            &#39;type&#39; => &#39;integer&#39;,
          ),          &#39;username&#39; => 
          array (            &#39;type&#39; => &#39;keyword&#39;,
          ),
        ),
      ),
    ),
  ),
)

로그인 후 복사

여기에서 얻은 관련 정보는 방금 생성한 인덱스 es를 동적으로 수정하고 관련 정보를 추가할 수 있다는 것입니다.

2.3 수정 /매핑 정보 추가

참고: 설정된 필드 유형은 변경할 수 없습니다!!
인터페이스: $client->indices()->putMapping();

        $params = [            &#39;index&#39; => &#39;user_index&#39;,  //索引名（相当于mysql的数据库）
            &#39;type&#39;  => &#39;normal_type&#39;,            &#39;body&#39;  =>  [                &#39;normal_type&#39; => [                    &#39;properties&#39;    =>[                        &#39;tag&#39;   =>[                            &#39;type&#39;  => &#39;text&#39;
                        ]
                    ]
                ]
            ]
        ];
$client->indices()->putMapping($params);

로그인 후 복사

2.4 인덱스 삭제

인터페이스:$ client->indices()->delete($params);

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

로그인 후 복사

3 es 추가, 삭제, 수정 및 확인

3.1 데이터 추가

단일 데이터 삽입
인터페이스: $client-> index()

$params = [    &#39;index&#39; => &#39;my_index&#39;,    &#39;type&#39; => &#39;my_type&#39;,    &#39;id&#39; => &#39;my_id&#39;, // 不填则es会自动生成唯一的id
    &#39;body&#39; => [ &#39;testField&#39; => &#39;abc&#39;]
];
$response = $client->index($params);

로그인 후 복사

일괄 데이터 삽입
인터페이스: $client->bulk();

                foreach($userList as $value){
                    $params[&#39;body&#39;][] = [                        &#39;index&#39; => [                            &#39;_index&#39; => &#39;user_index&#39;,                            &#39;_type&#39; => &#39;normal_type&#39;,                            &#39;_id&#39;  =>$value[&#39;uid&#39;]
                        ]
                    ];
                    $params[&#39;body&#39;][] = [                        &#39;uid&#39; => $value[&#39;uid&#39;],                        &#39;username&#39; => $value[&#39;username&#39;],                        &#39;platform&#39; => $value[&#39;platform&#39;],                        &#39;mobile&#39; => $value[&#39;mobile&#39;],                        &#39;province&#39; => $value[&#39;province&#39;],                        &#39;city&#39; => $value[&#39;city&#39;],                        &#39;sex&#39; => $value[&#39;gender &#39;],                        &#39;source&#39;=>&#39;xxx&#39;
                    ];
                }
                $responses = $client->bulk($params);

로그인 후 복사

ps: 루프에 데이터 양이 많으면 PHP의 메모리 제한 문제에 주의해야 합니다. (이 프레임워크의 어느 부분이 작업 후 메모리를 해제하지 않는지는 확실하지 않습니다.)

3.2 데이터 검색

단일 데이터 검색이지만 ID를 알아야 합니다
인터페이스: $client->get ()

$params = [    &#39;index&#39; => &#39;my_index&#39;,    &#39;type&#39; => &#39;my_type&#39;,    &#39;id&#39; => &#39;my_id&#39; // es 自动生成/自己录入的];
$response = $client->get($params);

로그인 후 복사

일괄 검색
인터페이스: $client->search()

$params = [  
    &#39;index&#39; =>  &#39;my_index&#39;,   //[&#39;my_index1&#39;, &#39;my_index2&#39;],可以通过这种形式进行跨库查询  
    &#39;type&#39; => &#39;my_type&#39;,//[&#39;my_type1&#39;, &#39;my_type2&#39;],  
    &#39;body&#39; => [  
        &#39;query&#39; => [  
            &#39;match&#39; => [  // 搜索条件
                &#39;age&#39; => &#39;24&#39; ,                &#39;tag.tagName&#39; =>&#39;tag&#39;  // 如果字段存储的是object.
                                       //这里搜索必须要这样才能搜索出结果.
            ]  
        ],  
        &#39;from&#39; => &#39;0&#39;,  // 分页
        &#39;size&#39; => &#39;200&#39;  // 每页数量
        &#39;sort&#39; => [  // 排序
            &#39;age&#39; => &#39;desc&#39;   //对age字段进行降序排序  
        ]  
    ]  
];  
$res = $client->search($params);

로그인 후 복사

반환된 데이터는 대략 다음과 같습니다.

array (size=4)  &#39;took&#39; => int 2
  &#39;timed_out&#39; => boolean false
  &#39;_shards&#39; => 
    array (size=3)      &#39;total&#39; => int 5
      &#39;successful&#39; => int 5
      &#39;failed&#39; => int 0
  &#39;hits&#39; =>  // 搜索到数据
    array (size=3)      &#39;total&#39; => int 2
      &#39;max_score&#39; => float 1
      &#39;hits&#39; => // 具体数据包
        array (size=1)          0 => 
            array (size=5)
              ...

로그인 후 복사

필요한 경우가 많아 mysql/or Query es 검색도 가능합니다.
이번에는 es 조합 필터를 사용하겠습니다
https://www.elastic.co/guide/cn/elasticsearch/guide/current/ Combine-filters.html 공식 문서는 다음과 같습니다
다음은 테스트한 예입니다

{    "index": "xxx_index", 
    "type": "normal_type", 
    "body": {        "size": 20, 
        "from": 0, 
        "query": {            "bool": {                "must": [
                    {                        "match": {                            "tag.tagName": "xxxx"
                        }
                    }
                ]
            }
        }, 
        "sort": {            "uid": "desc"
        }
    }
}

로그인 후 복사

3.3 데이터 삭제

참고: 데이터가 삭제되는 특정 캐시 업데이트 시간이 있으며, 업데이트되지 않은 경우에도 계속 업데이트됩니다.
인터페이스: $client->delete( );

$param = [                &#39;index&#39; => &#39;my_index&#39;,                &#39;type&#39; => &#39;my_type&#39;,                &#39;id&#39;    => &#39;my_id&#39;
            ];
            $ret = $this->client->delete($param);

로그인 후 복사

반환된 데이터는 다음과 같습니다:

array (size=7)  &#39;found&#39; => boolean true
  &#39;_index&#39; => string &#39;user_index&#39; (length=10)  &#39;_type&#39; => string &#39;normal_type&#39; (length=11)  &#39;_id&#39; => string &#39;AVzh_QnIZvcaH3gE7MvE&#39; (length=20)  &#39;_version&#39; => int 2
  &#39;result&#39; => string &#39;deleted&#39; (length=7)  &#39;_shards&#39; => 
    array (size=3)      &#39;total&#39; => int 2
      &#39;successful&#39; => int 1
      &#39;failed&#39; => int 0

로그인 후 복사

3.4 업데이트 데이터

인터페이스: $client->update()

$params = [  
    &#39;index&#39; => &#39;my_index&#39;,  
    &#39;type&#39; => &#39;my_type&#39;,  
    &#39;id&#39; => &#39;3416a75f4cea9109507cacd8e2f2aefc&#39;,  
    &#39;body&#39; => [  
        &#39;doc&#39; => [  // 必须带上这个.表示是文档操作
            &#39;age&#39; => 150  
        ]  
    ]  
];  
$res = $client->update($params);

로그인 후 복사

반환 결과

array (size=6)  &#39;_index&#39; => string &#39;user_index&#39; (length=10)  &#39;_type&#39; => string &#39;normal_type&#39; (length=11)  &#39;_id&#39; => string &#39;AVzh_QnIZvcaH3gE7Mw5&#39; (length=20)  &#39;_version&#39; => int 2
  &#39;result&#39; => string &#39;updated&#39; (length=7)  &#39;_shards&#39; => 
    array (size=3)      &#39;total&#39; => int 2
      &#39;successful&#39; => int 1 // 当数据没有发生变化时这里是为0
      &#39;failed&#39; => int 0

로그인 후 복사

4. indexes

참고: 서로 다른 인덱스 간에 데이터를 반전하는 경우 필드 유형에 주의해야 합니다. 유형이 다르면 가져오기가 실패할 수 있습니다. 이때 처리용 스크립트를 사용할 수 있습니다
이 인터페이스입니다. phpapi에서는 실행할 수 없으며 레코드로 존재합니다
인터페이스: 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
      }
    }
  }
}

로그인 후 복사

저자: Tang Minzheng
링크:https://www.jianshu.com /p/a2837f487de6