amazon web services - AWS SQS practical code PHP -

-

i had question here
i'm still missing point understanding how use sqs, out code please.

question: 1 place inside sqs?
i've read through amazons tutorial , concept seems lovely im missing practical side of things.
instance, diagram great: http://awsmedia.s3.amazonaws.com/catalog/images/159-for-madhu.png
go inside sqs? understand how upload s3, still grey sqs part

require_once('sdk-1.5.6.2/sdk.class.php'); //random strings $aws_key = "my_access_key"; $aws_secret_key = "my_secret_key";   //create new sqs queue , grab queue url $sqs = new amazonsqs(array( "key" => $aws_key, "secret" => $aws_secret_key )); $response = $sqs->create_queue('test-topic-queue'); $queue_url = (string) $response->body->createqueueresult->queueurl; $queue_arn = 'arn:aws:sqs:us-east-1:encq8gqracxv:test-topic-queue';    $queue_arn = 'arn:aws:sqs:us-east-1:encq8gqracxv:test-topic-queue'; $topic_arn = 'arn:aws:sns:us-east-1:encq8gqracxv:test-topic'; $response = $sns->subscribe($topic_arn, 'sqs', $queue_arn); $subscription_arn = (string) $response->body->subscriberesult->subscriptionarn;     /*  *   * * * * * * * * * * * * * * * *       big grey area, happens here ???   *   * * * * * * * * * * * * * * * * */    // delete sqs queue $queue_url = 'https://sqs.us-east-1.amazonaws.com/encq8gqracxv/test-topic-queue';  $response = $sqs->delete_queue($queue_url);

you should have 2 processes, 1 inserts messages queue , worker threads. typical worker thread this:

while(true) {     $res = $client->receivemessage(array(         'queueurl'          => $url,         'waittimeseconds'   => 1     ));     if ($res->getpath('messages')) {          foreach ($res->getpath('messages') $msg) {             echo "received msg: ".$msg['body'];              // useful $msg['body'] here              $res = $client->deletemessage(array(                 'queueurl'      => $url,                 'receipthandle' => $msg['receipthandle']             ));         }     } }

the waittimeseconds parameters means "long polling" , has various benefits (see http://docs.aws.amazon.com/awssimplequeueservice/latest/sqsdeveloperguide/sqs-long-polling.html).

you should use supervise or monit make sure worker threads stay running.

update: api v3 use get() instead of getpath() - getpath deprecated


Comments

Post a Comment

Popular posts from this blog

c# - SVN Error : "svnadmin: E205000: Too many arguments" -

-
i trying reposotries using c# code process svncommand = null; var psi = new processstartinfo("svnadmin"); psi.redirectstandardoutput = true; psi.redirectstandarderror = true; psi.useshellexecute = false; psi.arguments= @"dump c:\repositories\myrepo > c:\temp\myrepodumpfile.dump"; using (svncommand = process.start(psi)) { var myoutput = svncommand.standardoutput; var myerror = svncommand.standarderror; debug.write("output :" + environment.newline + environment.newline + myoutput.readtoend() + environment.newline + "error :" + environment.newline + environment.newline + myerror.readtoend()); svncommand.close(); } when use dump command commandline svnadmin dump c:\repositories\myrepo > c:\temp\myrepodumpfile.dump it works fine when try ...
Read more

c++ - Using OpenSSL in a multi-threaded application -

-
i have been writing soap client application in c++ on ubuntu using openssl https transport , pthreads threading. have number of threads - 1 central data acquisition thread periodically gets worker threads make soap requests via shared mutex protected queues. reading documentation openssl found is openssl thread-safe? in openssl faq describes mechanisms required ensure thread safety when using openssl. implemented , works fine. the reason question conceptual difficulty really. thinking implementing same functionality application has already, instead of using threads, create 2 seperate applications : 1 worker thread (of multiple copies running) , main data acquisition thread. use tcp sockets communicate between 2 rather mutex protected queues. may bad idea not important - confusing me would have implement same functions required ensure openssl thread safety in second approach or not? my guess not have , treated independent (indeed surely must many applications use openssl) re...
Read more

All overlapping substrings matching a java regex -

-
is there api method returns (possibly overlapping) substrings match regular expression? for example, have text string: string t = 04/31 412-555-1235; , , have pattern: pattern p = new pattern("\\d\\d+"); matches strings of 2 or more characters. the matches are: 04, 31, 412, 555, 1235. how overlapping matches? i want code return: 04, 31, 41, 412, 12, 55, 555, 55, 12, 123, 1235, 23, 235, 35. theoretically should possible -- there obvious o(n^2) algorithm enumerates , checks substrings against pattern. edit rather enumerating substrings, safer use region(int start, int end) method in matcher . checking pattern against separate, extracted substring might change result of match (e.g. if there non-capturing group or word boundary check @ start/end of pattern). edit 2 actually, it's unclear whether region() expect zero-width matches. specification vague, , experiments yield disappointing results. for example: string line = "xx90xx"; strin...
Read more