WebService::Async でウェブサービスの非同期アクセスを簡単に! あるいは私は如何にしてMacBookProを手に入れたか？

サンプルコード

use WebService::Async;
use WebService::Async::Parser::JSON;
my $wa = WebService::Async->new(
    base_url => 'http://ajax.googleapis.com/ajax/services/language/translate',
    param    => { v => '1.0', langpair => 'en|it' },
    response_parser => WebService::Async::Parser::JSON->new,
    on_done         => sub {
        my ( $service, $id, $res, $req ) = @_;
        print $req->param->{'q'} . " => ";
        print "$res->{responseData}->{translatedText}\n";
    },
);
$wa->add_get( q => 'apple' );
$wa->add_get( q => 'orange' );
$wa->add_get( q => 'banana', langpair => 'en|fr' );
$wa->send_request;    # sending three requests in parallel.

実行結果

orange => arancione       ※英語→イタリア語
banana => la banane       ※英語→フランス語
apple => mela             ※英語→イタリア語

手順

1. new する時に「URL」と「パラメータ」と「アクセス完了時のコールバック」を書いてやる。
2. add_get メソッドで追加のパラメータを渡してリクエストを追加する。
3. send_request メソッドで実際にリクエストを投げる。

という感じで、デフォルトでは AnyEvent とかを意識せずに書くことができます。

100個とか同時に投げたりした場合には、ドメインごとに4並列とかでキューを捌いてくれます。

※ new 時に、auto_block => 0 を指定することで send_request 時にブロックしないようにすることもできます。

※ on_done に加えて、on_complete を使うと、全てのアクセスが完了した場合のコールバックを書くことができます。

※ on_done の引数の $id は、個々のリクエストを識別するためのキーとなっています。id は自分で指定することも自動で生成されたものを使うことも、使わずにクエリのパラメータをキー代わりにしのぐこともできます。

※ その他色々な書き方はPODを参照ください

サンプルコード

use Cache::Memcached;
use WebService::Async;
use WebService::Async::Parser::JSON;
use WebService::Async::ResponseCache;

use FindBin qw($Bin);
use Log::Dispatch::Config;
use Log::Dispatch::Configurator::YAML;
my $configure =
  Log::Dispatch::Configurator::YAML->new("${Bin}/log_config.yaml");
Log::Dispatch::Config->configure($configure);
my $logger = Log::Dispatch::Config->instance;

my $wa = WebService::Async->new(
    base_url => 'http://ajax.googleapis.com/ajax/services/language/translate',
    param    => {
        v        => '1.0',
        langpair => 'en|fr',
    },
    auto_block      => 1,
    response_parser => WebService::Async::Parser::JSON->new,
    logger          => $logger,
);
$wa->response_cache(
    WebService::Async::ResponseCache->new(
        cache => Cache::Memcached->new( { servers => ['localhost:11211'] } )
    )
);
$wa->add_get(
    id    => 1,
    lang  => 'en',
    param => { q => 'apple' }
);
$wa->add_get(
    id    => 2,
    lang  => 'en',
    param => { q => 'banana' }
);
my $result = $wa->send_request()

実行結果 一回目: キャッシュにセットされる

[Wed Sep 29 10:23:25 2010] [info] Does not hit any caches: http://ajax.googleapis.com/ajax/services/language/translate?q=banana&v=1.0&langpair=en%7Cfr at /opt/perl/lib/site_perl/5.10.0/WebService/Async.pm line 111
[Wed Sep 29 10:23:25 2010] [info] Does not hit any caches: http://ajax.googleapis.com/ajax/services/language/translate?q=apple&v=1.0&langpair=en%7Cfr at /opt/perl/lib/site_perl/5.10.0/WebService/Async.pm line 111
[Wed Sep 29 10:23:25 2010] [debug] Cache set at: http://ajax.googleapis.com/ajax/services/language/translate?q=apple&v=1.0&langpair=en%7Cfr at /opt/perl/lib/site_perl/5.10.0/WebService/Async.pm line 111
[Wed Sep 29 10:23:27 2010] [debug] Cache set at: http://ajax.googleapis.com/ajax/services/language/translate?q=banana&v=1.0&langpair=en%7Cfr at /opt/perl/lib/site_perl/5.10.0/WebService/Async.pm line 111

実行結果 二回目： キャッシュ結果が使われる

[Wed Sep 29 10:12:52 2010] [info] Cache hit: http://ajax.googleapis.com/ajax/services/language/translate?q=banana&v=1.0&langpair=en%7Cfr?q=banana&v=1.0&langpair=en%7Cfr at /opt/perl/lib/site_perl/5.10.0/WebService/Async.pm line 111
[Wed Sep 29 10:12:52 2010] [info] Cache hit: http://ajax.googleapis.com/ajax/services/language/translate?q=apple&v=1.0&langpair=en%7Cfr?q=apple&v=1.0&langpair=en%7Cfr at /opt/perl/lib/site_perl/5.10.0/WebService/Async.pm line 111