‚�ｿｽ}‚ÌWebƒT[ƒrƒX‚ÍAsinatra on GAE/JRuby ‚Æ‚�ｿｽ�ｿｽ‚¤\�ｿｽ�ｿｽ‚Åì‚Á‚Ä‚ ‚é‚Ì‚¾‚¯‚ÇAŽÀ‚Í4A5“ú’ö“x‚łЂƂƂ�ｿｽN‚è‚Ì‹@”\‚ª“®ì‚·‚é‚‚ç‚�ｿｽ�ｿｽ‚É‚È‚Á‚Ä‚�ｿｽ�ｿｽ‚½B
•Ê‚ÉGAEƒoƒ“ƒUƒC‚ÆŒ¾‚�ｿｽ�ｿｽ‚½‚�ｿｽ�ｿｽ–ó‚Å‚Í‚È‚‚ÄA–{‘è‚Í‚�ｿｽ}‚�ｿｽ}‚©‚çB
GAE‚Á‚Ä�ｿｽ�ｿｽŒÀ‚ª‘½‚‚ ‚é‚Ì‚ÅA‚�ｿｽ}‚ê‚ð‰ñ”ð‚·‚é‚Ì‚ªŒ‹\‘å•ÏB‚³‚ç‚Éuƒ}ƒPƒvƒŒEƒtƒ‰ƒOv‚͉¿Šiî•ñ‚𓾂邽‚ß‚ÉAmazon‚ÌProduct Advertising API‚ðŽg‚Á‚Ä‚�ｿｽ�ｿｽ‚ÄAŽÀ‚Í‚�ｿｽ}‚¿‚ç‚É‚à�ｿｽ�ｿｽŒÀ‚ª‚ ‚éB
GAE‚Í30•bˆÈ“à‚ɃŒƒXƒ|ƒ“ƒX‚ð•Ô‚³‚È‚‚Ä‚Í‚�ｿｽ�ｿｽ‚¯‚È‚�ｿｽ�ｿｽ
—˜—pŽÒ‚ª¤•iŒŸõ‚µ‚Ä30•b‚à‘Ò‚Á‚Ä‚‚ê‚é–ó‚Í‚È‚�ｿｽ�ｿｽ‚Ì‚ÅA‚»‚ê‚Í–â‘è‚É‚È‚ç‚È‚�ｿｽ�ｿｽ(‚Æ‚�ｿｽ�ｿｽ‚¤‚æ‚è30•b‚à‘Ò‚½‚¹‚é‚È‚çGAE‚ÉŠÖŒW‚È‚ÝŒv‚ðŒ©’¼‚·‚Å‚µ‚å)B
–â‘è‚ÍAcron‚ÅŽÀs‚·‚é‚悤‚ȃoƒbƒ`ˆ—‚à“¯—l‚Ì�ｿｽ�ｿｽŒÀ‚ª‚ ‚é‚Æ‚�ｿｽ�ｿｽ‚¤‚�ｿｽ}‚ÆB
uƒ}ƒPƒvƒŒEƒtƒ‰ƒOv‚Å‚ÍA“o˜^‚³‚ê‚Ä‚�ｿｽ�ｿｽ‚é‘S‚Ă̤•i‚̉¿Ši‚ð’èŠú“I‚ðƒ`ƒFƒbƒN‚·‚é•K—v‚ª‚ ‚éB“–‘R30•b‚Å‘S‚ă`ƒFƒbƒN‚Å‚«‚È‚�ｿｽ�ｿｽB
‚Ü‚½AŠó–]‚ÌŠ„ˆø—¦‚ðã‰ñ‚ê‚΃[ƒ‹‚ð—˜—pŽÒ‚É‘—‚éB1’Ê‚¾‚¯‚È‚ç–â‘è‚È‚�ｿｽ�ｿｽ‚¯‚ÇA•¡”‚Ì—˜—pŽÒ‚É‘—‚é‚�ｿｽ}‚Æ‚É‚È‚é‚Ì‚ÅA‚�ｿｽ}‚ê‚à30•b‚ÅI‚í‚ç‚È‚�ｿｽ�ｿｽB
‘Έ–@
ˆ—‚𕪊„‚µ‚ÄTaskQueue‚ð—˜—p‚·‚éB
uƒ}ƒPƒvƒŒEƒtƒ‰ƒOv‚Å‚ÍA‘å—ʂɉ¿Šiƒ`ƒFƒbƒN‚·‚鈗‚ª‚ ‚é‚Ì‚ÅA¤•i–ˆ‚É•ªŠ„‚µ‚ÄTaskQueue‚ðŽg‚Á‚Ä‚Ý‚½B
GAE/JRuby‚ÅTaskQueue‚ðŽg‚¤‚É‚ÍAcron‚Æ“¯—l‚ÉURL‚ð’@‚‚¾‚¯B
require 'appengine-apis/labs/taskqueue'
queue = AppEngine::Labs::TaskQueue::Queue.new
task = AppEngine::Labs::TaskQueue::Task.new(:url => '/taskqueue_sample')
queue.add task
‚�ｿｽ}‚ꂾ‚¯‚ÅŽg‚¦‚éB
GAE‚Í•‰‰�ｿｽ~‚ª‚©‚©‚Á‚Ä‚�ｿｽ�ｿｽ‚é‚Æ‚«‚Í10•bˆÈ“à‚Ɉ—‚µ‚È‚¯‚ê‚΂�ｿｽ�ｿｽ‚¯‚È‚�ｿｽ�ｿｽ
¡‰ñWebƒT[ƒrƒX‚ðì‚é‚Ü‚ÅA30•b�ｿｽ�ｿｽŒÀ‚Í—L–¼‚È‚Ì‚Å’m‚Á‚Ä‚�ｿｽ�ｿｽ‚½‚¯‚ÇA‚�ｿｽ}‚Á‚¿‚Í’m‚ç‚È‚©‚Á‚½B
"Request was aborted after waiting too longEEE"‚Æ‚�ｿｽ�ｿｽ‚¤ƒGƒ‰[‚ªo‚Ä‚�ｿｽ�ｿｽ‚éꇂÍA‚�ｿｽ}‚Ì�ｿｽ�ｿｽŒÀ‚Ɉø‚Á‚©‚©‚Á‚Ä‚�ｿｽ�ｿｽ‚éB
‰¿Ši‚ðƒ`ƒFƒbƒN‚·‚邽‚ß‚ÉTaskQueue‚ðŽg‚Á‚ÄAPIŒÄ‚Ño‚µ‚ð‘å—Ê‚É‚µ‚Ä‚�ｿｽ�ｿｽ‚½‚çA‚�ｿｽ}‚̃Gƒ‰[‚ª”�ｿｽ�ｿｽ‚µ‚Ä‚�ｿｽ�ｿｽ‚½BTaskQueue‚ÍŽ¸”s‚·‚é‚ÆAŸŽè‚ɃŠƒgƒ‰ƒC‚µ‚Ä‚‚ê‚é‚Ì‚ÅA“®ìŽ©‘Ì‚Í‚µ‚Ä‚�ｿｽ�ｿｽ‚邯‚ÇAƒŠƒ\[ƒX‚ª‚à‚Á‚½‚�ｿｽ�ｿｽ‚È‚�ｿｽ�ｿｽB
‘Έ–@
10•bˆÈ“à‚Ɉ—‚ªI‚í‚é‚悤‚É•ªŠ„‚·‚é‚©A•‰‰�ｿｽ~‚ð‚©‚¯‚È‚�ｿｽ�ｿｽ‚©A‚Ì2‘ð‚ðl‚¦‚ÄAŒãŽÒ‚őΉž‚µ‚½B
‰¿Šiƒ`ƒFƒbƒN‚̓oƒbƒ`ˆ—‚È‚Ì‚Å—˜—pŽÒ‚̃ŒƒXƒ|ƒ“ƒX‚ɂ͉e‹¿‚È‚�ｿｽ�ｿｽ‚Ì‚ÅATaskQueue‚ðŠÔŠu‚ð‹ó‚¯‚ÄŽÀs‚·‚é‚�ｿｽ}‚Æ‚É‚µ‚½B
TaskQueue‚Ícountdown‚Æ‚�ｿｽ�ｿｽ‚¤ˆø”‚ÅA‚»‚Ì•b”•ª‘Ò‚Á‚Ä‚©‚çŽÀs‚·‚é‚悤‚ÉŽw’è‚Å‚«‚éB
queue = AppEngine::Labs::TaskQueue::Queue.new
products = Product.all()
cnt = 0
for product in products
task = AppEngine::Labs::TaskQueue::Task.new(:url => '/taskqueue_sample', :countdown => cnt)
queue.add task
cnt += 3
end
¡‰ñ‚ÍA‚�ｿｽ}‚̂悤‚ÉA3•b‚�ｿｽN‚«‚ÉŽÀs‚·‚é‚悤‚É‚µ‚½‚çAƒGƒ‰[‚ªo‚È‚‚È‚Á‚½B
GAE‚̃Xƒsƒ“ƒAƒbƒv‚ÉŽžŠÔ‚ª‚©‚©‚é
‚à‚µ‚©‚·‚é‚ÆAGAE‚ðpython‚Å—˜—p‚µ‚Ä‚�ｿｽ�ｿｽ‚½‚èAƒtƒŒ[ƒ€ƒ[ƒN‚ð‹²‚Ü‚¸—˜—p‚µ‚Ä‚�ｿｽ�ｿｽ‚ê‚Αåä•v‚È‚Ì‚©‚à‚µ‚ê‚È‚�ｿｽ�ｿｽB
GAE‚Í—˜—pŽÒ‚©‚ç‚̃AƒNƒZƒX‚ª‚È‚�ｿｽ�ｿｽ‚Æ‚·‚®ƒXƒsƒ“ƒ_ƒEƒ“‚·‚éBƒXƒsƒ“ƒ_ƒEƒ“Œã‚̉‰ñƒAƒNƒZƒX‚̓Xƒsƒ“ƒAƒbƒv‚̈—‚ÉŽžŠÔ‚ª‚©‚©‚éB
¡‰ñAsinatra on GAE/JRuby‚Æ‚�ｿｽ�ｿｽ‚¤AJavaVMARubyAsinatra‚Æ‚�ｿｽ�ｿｽ‚¤3’i\�ｿｽ�ｿｽ‚Åì‚Á‚Ä‚µ‚Ü‚Á‚½‚½‚ßAƒXƒsƒ“ƒAƒbƒv‚ÌŽžŠÔ‚ª‚·‚²‚�ｿｽ�ｿｽ‚�ｿｽ}‚Æ‚É‚È‚Á‚Ä‚�ｿｽ�ｿｽ‚éB20•b‚ð—]—T‚Å’�ｿｽL‚¦‚éB
ðŒ‚ªˆ«‚�ｿｽ�ｿｽ‚ÆAƒXƒsƒ“ƒAƒbƒv‚·‚邾‚¯‚ÅAæ‚Ì30•b�ｿｽ�ｿｽŒÀ‚Ɉø‚Á‚©‚©‚é‚ñ‚�ｿｽ�ｿｽ‚á‚È‚�ｿｽ�ｿｽ‚©‚ÆŽv‚¤‚Æ‚«‚à‚ ‚Á‚½B(sinatra‚Å‚�ｿｽ}‚ñ‚Èó‘Ô‚È‚Ì‚ÉRails‚ÅŽÀ‰^—p‚Å‚«‚é‚Ì‚¾‚낤‚©B)
ƒoƒbƒ`ˆ—‚Ì‚Æ‚«‚ɃXƒsƒ“ƒAƒbƒv‚·‚é‚È‚ç‚Æ‚à‚©‚A—˜—pŽÒ‚ªƒAƒNƒZƒX‚µ‚½ƒ^ƒCƒ~ƒ“ƒO‚ŃXƒsƒ“ƒAƒbƒv‚³‚ê‚é‚ÆAƒy[ƒW‚ð•\Ž¦‚·‚é‚Ü‚ÅA20‚©‚ç25•b‹ß‚‘Ò‚½‚¹‚é–ó‚ÅAŽ©•ª‚ª—˜—pŽÒ‚È‚ç‚»‚ÌŽž“_‚Å‹A‚éB
‘Έ–@
d—Ê‹‰‚̃tƒŒ[ƒ€ƒ[ƒN‚ðŽg‚í‚È‚�ｿｽ�ｿｽ‚Æ‚�ｿｽ�ｿｽ‚¤‚Ì‚à‘Έ–@‚¾‚¯‚Ç¡‰ñ‚Í‚·‚Å‚ÉŽž’x‚µB
uƒ}ƒPƒvƒŒEƒtƒ‰ƒOv‚Å‚ÍAŽd•û–³‚1A2•ª‚�ｿｽN‚«‚Écron‚ʼn½‚à‚µ‚È‚�ｿｽ�ｿｽƒ_ƒ~[‚ÌURL‚ɃAƒNƒZƒX‚·‚é‚�ｿｽ}‚Æ‚ÅAƒXƒsƒ“ƒ_ƒEƒ“‚µ‚È‚�ｿｽ�ｿｽ‚悤‚É‚µ‚Ä‚�ｿｽ�ｿｽ‚éB‚½‚¾A‚�ｿｽ}‚Ì•û–@‚Í‚Å‚«‚ê‚΂â‚ç‚È‚�ｿｽ�ｿｽ‚Å—~‚µ‚�ｿｽ�ｿｽ‚Æ‚�ｿｽ�ｿｽ‚¤‚�ｿｽ}‚Ƃ炵‚�ｿｽ�ｿｽB
‚Å‚àA‘¼‚ɉñ”ðô‚ª‚È‚�ｿｽ�ｿｽ‚Ì‚ÅA¡‚Ì‚Æ‚�ｿｽ}‚ë‚Í‚�ｿｽ}‚Ì‚Ü‚Ü‚ÅB
GAE‚Ì–³—¿ƒŠƒ\[ƒX‚¾‚ƃ[ƒ‹‚ð1•ª‚É8’Ê‚Ü‚Å‚Ì‘—M‚É‚µ‚È‚�ｿｽ�ｿｽ‚Æ‚�ｿｽ�ｿｽ‚¯‚È‚�ｿｽ�ｿｽ
GAE‚ð–³—¿ƒŠƒ\[ƒX“à‚Å—˜—p‚·‚éê‡Aƒ[ƒ‹‘—M‚Í1•ª‚É8’Ê‚Ü‚Å‚Æ‚�ｿｽ�ｿｽ‚¤�ｿｽ�ｿｽŒÀ‚ª‚ ‚éBAmazon‚ÌAPI‚Í1•b‚É1‰ñˆÈã‚̃AƒNƒZƒX‚𑽂µ‚Ä‚à‘åä•v‚¾‚Á‚½‚è‚·‚邯‚ÇAGAE‚Í‘�ｿｽ�ｿｽU‚Å—áŠO‚É‚È‚é‚Ì‚Å’ˆÓB
‘Έ–@
Memcache‚ÉÅŒã‚É‘—M‚µ‚½Žž‚ð•ÛŽBƒ[ƒ‹‚ð‘—M‚·‚é‚Æ‚«‚ÉA‚»‚ÌŽž‚ðŠm”F‚µ‚ÄA8•b’ö“x‚ÌŠÔŠu‚æ‚è’Z‚©‚�ｿｽ�ｿｽꇂɑ҂‚悤‚É‚·‚éB
TaskQueue‚Í•À—ñˆ—‚È‚Ì‚ÅMemcache‚ðŽg‚¤‚Æ‚«‚É”r‘¼�ｿｽ�ｿｽŒä‚µ‚Ä‚�ｿｽN‚©‚È‚�ｿｽ�ｿｽ‚Æ‚�ｿｽ�ｿｽ‚¯‚È‚�ｿｽ�ｿｽB
Memcache‚ŃXƒsƒ“ƒƒbƒN‚ðŽÀ‘•‚µ‚ÄTask Queueˆ—Œ‹‰Ê‚ðW–ñ‚µ‚Ä‚Ý‚éƒeƒXƒg
”r‘¼�ｿｽ�ｿｽŒä‚Íã‹LƒTƒCƒg‚̂悤‚Émutex‚ðŽÀ‘•‚µ‚½acquireLock‚ÆAreleaseLock‚ð—˜—pB
acquireLock('mail_lock')
last_send = memcache.get('last_sendmail')
if not last_send.nil? then
sleep(8 - (Time.now - last_send))
end
memcache.set('last_sendmail', Time.now, 8)
releaseLock('mail_lock')
‚�ｿｽ}‚ñ‚ÈŠ�ｿｽL‚�ｿｽ�ｿｽ‚ÅMemcache‚Ì—LŒøŠúŠÔ‚ð8•b‚ŃZƒbƒg‚µ‚ÄAMemcache‚ÉŽž‚ª•ÛŽ‚³‚ê‚Ä‚�ｿｽ�ｿｽ‚½ê‡‚ÉA‚»‚ÌŽž‚©‚ç8•b‰ß‚�ｿｽ�ｿｽ‚é‚܂ő҂‚悤‚É‚µ‚½B
Product Advertising API‚ÍA1•b‚É1‰ñˆÈナƒNƒGƒXƒg‚µ‚Ä‚Í‚�ｿｽ�ｿｽ‚¯‚È‚�ｿｽ�ｿｽ
API‚ðŒÄ‚Ñ‚¾‚µ‚½‚çA1•b‘҂‚悤‚Éì‚ê‚΂�ｿｽ�ｿｽ‚�ｿｽ�ｿｽ‚Æ‚�ｿｽ�ｿｽ‚¤–ó‚�ｿｽ�ｿｽ‚á‚È‚�ｿｽ�ｿｽBWebƒT[ƒrƒX‘S‘Ì‚Å1•b‚É1‰ñˆÈナƒNƒGƒXƒg‚µ‚Ä‚Í‚�ｿｽ�ｿｽ‚¯‚È‚�ｿｽ�ｿｽ‚Æ‚�ｿｽ�ｿｽ‚¤‚Æ‚�ｿｽ}‚낪ƒ|ƒCƒ“ƒgB
uƒ}ƒPƒvƒŒEƒtƒ‰ƒOv‚Å‚ÍA—˜—pŽÒ‚ª¤•iŒŸõ‚·‚éA¤•iƒy[ƒW‚ð•\Ž¦‚·‚é‚Æ‚«‚âcron‚Å’èŠú“I‚ɉ¿Ši‚ðƒ`ƒFƒbƒN‚·‚é‚Æ‚«‚ÉAPI‚ðŒÄ‚Ño‚·B
—Ⴆ‚ΈႤƒ†[ƒU‚ª“¯Žž‚ɤ•i‚ðŒŸõ‚·‚ê‚ÎA1•b‚É1‰ñ‚Ì�ｿｽ�ｿｽŒÀ‚Ɉø‚Á‚©‚©‚é‰Â”\«‚ª‚ ‚éBcron‚Ť•i‚̉¿Ši‚ðƒ`ƒFƒbƒN‚µ‚Ä‚�ｿｽ�ｿｽ‚éÅ’†‚Ƀ†[ƒU‚ªƒy[ƒW‚ɃAƒNƒZƒX‚·‚ê‚ÎA‚©‚È‚è‚ÌŠm—¦‚ňø‚Á‚©‚©‚邾‚낤B
‘Έ–@
Memcache‚ÉÅŒã‚ÉAPI‚ŃAƒNƒZƒX‚µ‚½Žž‚ð•ÛŽB1•bˆÈ“à‚̘A‘�ｿｽ}ŒÄ‚Ño‚µ‚Ìꇂɑ҂‚悤‚É‚·‚éB
‚�ｿｽ}‚ê‚Íã‹L‚̃[ƒ‹‘—M‚Æ“¯—l‚ÌŽd‘g‚݂Ȃ̂ňȉºÈ—ªB
‚Ü‚Æ‚ß
‚�ｿｽ}‚̂悤‚ÉAŒ‹‹ÇA‰ñ”ð‚·‚éÝŒv‚ðl‚¦‚½‚èA•ÏX‚·‚é‚Ì‚ÉA‚³‚ç‚É4“ú’ö“x‚©‚©‚Á‚½B
GAE‚ÍŠÈ’P‚ɃT[ƒrƒX‚ðì‚ê‚é‚Ì‚¾‚¯‚ÇA‚�ｿｽ}‚¤‚�ｿｽ�ｿｽ‚¤�ｿｽ�ｿｽ–ñ‚ð‰ñ”ð‚µ‚Â‚ÂAƒ†[ƒU‚ª•s•Ö‚É‚È‚ç‚È‚�ｿｽ�ｿｽ‚悤‚ÉÝŒv‚·‚é‚Ì‚ÍAŽÀ‚Í‘å•Ï‚Æ‚�ｿｽ�ｿｽ‚¤A‚»‚¤‚�ｿｽ�ｿｽ‚¤˜bB
‚�ｿｽ}‚ê‚ç‚Ì�ｿｽ�ｿｽŒÀ‚Ì“àA‰ðÁ‚³‚ê‚é—\’è‚Ì‚à‚Ì‚ª‚ ‚é‚Ì‚ÅAŠú‘Ò‚µ‚Ä‚�ｿｽ�ｿｽ‚éB
Google App Engine‚̃[ƒhƒ}ƒbƒvB”¼”NˆÈ“à‚É30•b�ｿｽ�ｿｽŒÀ‚àƒXƒsƒ“ƒAƒbƒv‘Ò‚¿‚à“P”pH
‚ðŽg‚Á‚Ä‚�ｿｽ�ｿｽ‚é‚Ì‚¾‚ªA‚�ｿｽ}‚̃Cƒ„ƒzƒ“‚ðX01HT‚Å‚àŽg‚¦‚é‚悤‚ÉA•ÏŠ·ƒAƒ_ƒvƒ^[‚ðw“ü‚µ‚½B
