php mongodb extensionを使用する際の注意点_PHPチュートリアル
- WBOYオリジナル
- 2016-07-13 17:14:02848ブラウズ
最近、PHPのmongo拡張機能を使用して統計計算を実行しています。タイムスタンプフィールドはミリ秒単位の精度であるため、長さは13桁ですが、先頭は文字列の形式で保存されます。 :
| コードは次のとおりです | コードをコピー |
|
|
|
後にデジタル形式に変更されました:
| コードは次のとおりです | コードをコピー |
|
"{" _Id ": Objectid (" 504EEA97E4B023CF38E34039 ")、" In_TS ": Numberlong (" 1347349143699 ")、" LOG ": {" GUID " 2d5d8229d "、" p ":" View_Prop_YepPage_Zheng"、 "cid" : "11" 、「url」:「http://shanghai.haozu.com/rental/broker/n/10481780」、「rfpn」:「Listing_V2_IndexPage_All」、「サイト」:「haozu」、「エージェント」:「Mozilla/4.0 (互換性; MSIE 6.0; Windows NT SV1)"、"スタンプ" : NumberLong("1347349162159")、"リファラー" : "http://shanghai.haozu.com/shop /1464934/"、"cstamp" : "1347349323125"、"sessid" : "FA798056-F9E7-F961-41E0-CC95C850FA47"、"uguid" : "C00FF55B-3D3D-4B31- 4318-12345B0DBE64"、"ぷん" : " View_Prop_YepPage_Zheng", "cstparam" : { "proId" : NumberLong(10481780), "brokerId" : "326792", "tradeType" : "2", "userType" : "0" 、 "channel" : "site", "エントリ" : "1", "COMMID" : "1666" } }, "out_ts" : NumberLong("1347349466083"), "rule" : 0, "status" : "ok ", "txid" : 0 } は文字列、次のクエリを使用するのが通常です $query = array ('log.stamp' => array ('$gte' => '1347346800000', '$lt' => '1347350400000'));
|
|
| コードは次のとおりです | コードをコピー |
| db.haozu_success.find({'log.stamp':{$gte:1347346800000,$lt:1347350400000}}) | |
これは PHP マニュアルでも次のように使用されます:
| コードは次のとおりです | コードをコピー |
| $query = array ('log.stamp' => array ('$gte' => 1347346800000, '$lt' => 1347350400000)); | |
最初は、PHP 拡張機能のバグが原因ではないかと思いましたが、少し考えた結果、それが原因だと思いました。ふと、型の問題ではないかと思い立ち、マニュアルに型の紹介があったので、正しい使い方は以下の通りです
| コードは次のとおりです | コードをコピー |
|
$query = array ('log.stamp' => array ('$gte' => new MongoInt64($time_range['start']), '$lt' => new MongoInt64($time_range['end) ']))); |
|
さらに、データ統計にmapreduceを使用する場合、カーソルがタイムアウト例外を取得しないようにするために、タイムアウト期間を設定する必要があります
| コードは次のとおりです | コードをコピー |
| $map = 新しい MongoCode ( ' 関数(){ var prop_id=this.log.cstparam.proId; var key=this.log.site+prop_id Emit(key,{"channel":this.log.site,"prop_id":prop_id,"count":1}); } ' ); $reduce = 新しい MongoCode ( ' 関数(キー、発光){ var total=0; for(エミットの変数 i){ } return {"channel":emits[0].channel,"prop_id":eval(emits[0].prop_id),"count":total}; } ' ); $this->mongo_db->command ( array ('mapreduce' => $collection_name, 'map' => $map, 'reduce' => $reduce, 'out' => $tmp_result, 'クエリ' => $クエリ),配列('タイムアウト'=>self::MONGO_CURSOR_TIMEOUT) ); |
|