ラップメドシャ Pythonの実装のRedisのクエリクエリ
今すぐダウンロード

ラップメドシャ ランキングとまとめ

ラップメドシャ タグ

Pythonライブラリ Python. 訊く MapReduce.

ラップメドシャ 説明

RapMedusaは、Redisキーバリューストアを介してMapReduceクエリを実装するためのPythonモジュールです。 CouchDBのビューの機能とMongoDBのMapReduceデータベースCommand.DependenciesRapMedusaは、https://github.com/andymccurdy/dredisから入手可能なAndy McCurdyのRedis-Pyモジュールに依存します。 PY。もちろん、接続するためのRedisインスタンスも必要です。どちらの場合も、任意のバージョン> = 2.0がRapMedusa.Installationと互換性があるはずです.Sudo PipのインストールRapMedusaor Sudo Easy_install RapmedUsaoRソースから：sudo python setup.py installOverViewFirst：>>>インポートredis >>> 、map_reduceNext通常の方法で実行中のRedisインスタンスに接続します。>>> Redis = Redis.StricTredis（host = 'localhost'、port = 6379、db = 0）最後に、マップの実装と機能を減らす必要があります。 Redisサーバーへのアクティブな接続とともにMAP_REDUCE（）関数への呼び出しに渡されます。>>> DEF MyMap（キー、val）：... Emit（Newkey、NewVal）>>> DEF MyReduce（キー、値）：... Return NewVal >>> result = map_reduce（redis、mymap、myReduce）MapReduceジョブを実行した結果を含むPython Dictionaryオブジェクトを返します。辞書内の各キーは、reduce関数に渡されたキーに対応し、そのキー.detailsnowのredual関数によって計算された値を含みます。基本的には6つのステップがあります。 - 指定されたRedis Hashからの入力データセットを読み取ります。 Redisリストの1つのリストの1つは、これらのリストのそれぞれが登録されているredual関数に渡されます。 - 減少する各呼び出しの結果は、ジョブ出力用に予約されているRedisハッシュに格納されます。 reduce call.-ジョブ出力ハッシュの内容を表すPythonディクショナリが返されます。これらの（上記のステップで使用されている他の一時的なRedisキー）は、opplicationallyをmap_reduce（）への呼び出し内で指定できます。コールで指定できる追加のオプションのパラメータのリストが次のとおりです。ジョブ出力が格納されています（デフォルトは 'RapMedusa：Outputs'） - SortKey - マップ関数の出力（上記のステップ3）が格納されているキープレフィックスを指定します（デフォルトは 'Rapmedusa：SortedVals'） - SortedKeySet - ステップ3のリストキーから作成されたセットが格納されているキーを指定します（デフォルトは 'RapMedusa：SortedKeyset'） - クリーンアップ - 一時キー（SORTKEY、SORTEDKEESET）をRedis Storeから削除する必要があるかどうかを示すブール値MapReduceジョブが完了すると（デフォルトはTRUEに）、命名の競合が非常に低いため、SortedKeyとSortedKeySetのデフォルト値を上書きする必要があります。ただし、remotement.exampleSexampleのカウントajeSthisのカウント数は、入力キーが個人記録にマッピングされているMapReduceジョブを示し、マップ関数は1つに基づいてキーを生成するMapReduceジョブを示します。レコードエントリのうち、年齢>>>インポートRedis >>> Lapedusa Import * >>> conn = redis.strictRedis（host = 'localhost'、port = 6379、db = 0）>>> conn.hset（ 'myinput'、1、 "{ 'name'： 'chad'、 'age'：43} "）>>> conn.hset（ 'myinput'、2、" {'name'： 'ron'、 'age'：21} "）>>> conn.hset（ 'myinput'、3、 "{'name'、 'george'、 'age'：54}"）>>> conn.hset（ 'myinput'、4、 "{'name'： 'alice' 、 '歳'：54} "）>>> def mymap（キー、値）：obj = eval（value）emit（str（obj ）、 '1'）>>> def myreduce（キー、 VALS）：v in v in for vals：total + = int（v）return >>> result = map_reduce（conn、mymap、myreduce、inkey = 'myinput'）>>>印刷結果{'54'： ' 2 '、' 21 '：' 1 '、' 43 '：' 1 '}製品のホームページ

ラップメドシャ 関連ソフトウェア