{"id":17614,"date":"2020-08-30T18:12:28","date_gmt":"2020-08-30T18:12:28","guid":{"rendered":"https:\/\/www.gencayyildiz.com\/blog\/?p=17614"},"modified":"2020-08-30T18:12:28","modified_gmt":"2020-08-30T18:12:28","slug":"azure-functions-serisi-18-queue-trigger","status":"publish","type":"post","link":"https:\/\/www.gencayyildiz.com\/blog\/azure-functions-serisi-18-queue-trigger\/","title":{"rendered":"Azure Functions Serisi #18 – Queue Trigger"},"content":{"rendered":"

<\/div>\n

Merhaba,<\/p>\n

Bu i\u00e7eri\u011fimizde Azure Functions yaz\u0131 serisi<\/a>nin son makalesi olan Queue Trigger \u00fczerine irdelemede bulunuyor olaca\u011f\u0131z.<\/p>\n

Queue Trigger Nedir?<\/h4>\n
Azure Storage i\u00e7erisindeki herhangi bir queue servisindeki kuyru\u011fa mesaj geldi\u011finde tetiklenecek olan ve g\u00f6nderilen mesaj\u0131 elde edip i\u015flem yapmam\u0131z\u0131 sa\u011flayan bir trigger’d\u0131r. Kuyruktaki mesaj\u0131; string olarak<\/strong><\/em> yahut serialize edilmi\u015fse uygun entity’e deserialize ederek<\/strong><\/em> ya da Input Binding i\u015flemine tabii tutarak<\/strong><\/em> elde etmemizi sa\u011flar. T\u00fcm bunlar\u0131n d\u0131\u015f\u0131nda gelecek olan mesaja dair detaylar\u0131 g\u00f6rebilmemiz i\u00e7in CloudQueueMessage<\/strong><\/em> t\u00fcr\u00fcnden de elde ederek ekstra bilgiler edinebilmemizide sa\u011flamaktad\u0131r. \u0130\u00e7eri\u011fimizde t\u00fcm bu y\u00f6ntemleri tek tek ele al\u0131p mesajlar\u0131n nas\u0131l i\u015flendi\u011fini incelemi\u015f olaca\u011f\u0131z.<\/p>\n
Queue Trigger Olu\u015fturma<\/h4>\nVisual Studio \u00fczerinden Queue Trigger olu\u015fturman\u0131n di\u011fer trigger’lar\u0131n olu\u015fturulmas\u0131ndan pek fark\u0131 bulunmamaktad\u0131r.
\n $\"Azure$ <\/a>
\nBurada sa\u011f taraftaki men\u00fclerden bir \u00f6nceki Blob Trigger<\/a> ba\u015fl\u0131kl\u0131 yaz\u0131m\u0131zdakilerle benzer olanlar\u0131 birebir ayn\u0131 mahiyette i\u015flevselli\u011fe sahiptirler. \u0130lgili yaz\u0131daki alakal\u0131 b\u00f6l\u00fcm\u00fc queue trigger’a uyarlayarak burada al\u0131nt\u0131l\u0131yorum;<\/p>\n
\n
\n
Storage Account(AzureWebJobsStorage)<\/strong>
\nQueue Trigger\u2019\u0131n kullanaca\u011f\u0131 Azure Storage account\u2019unu se\u00e7iniz.\n<\/li>\n
Connection string setting name<\/strong>
\nKullan\u0131lacak Azure Storage\u2019\u0131n connection string de\u011ferini giriniz. E\u011fer bo\u015f ge\u00e7ersek default olarak local emulator\u2019de ki storage\u2019a ba\u011flant\u0131 sa\u011flanacakt\u0131r.\n<\/li>\n<\/ul>\n<\/blockquote>\n
Geriye bir tek ‘Queue Name’ alan\u0131 kalmaktad\u0131r. Bununda olu\u015fturulacak kuyru\u011fun ad\u0131 oldu\u011fu a\u015fikard\u0131r \ud83d\ude42<\/p>\n
\u0130lgili uygulamay\u0131 olu\u015fturduktan sonra kar\u015f\u0131m\u0131za gelen fonksiyona g\u00f6z atarsak e\u011fer;<\/p>\n
\r\n public static class Function1\r\n {\r\n [FunctionName("Function1")]\r\n public static void Run([QueueTrigger("myqueue-items", Connection = "")]string myQueueItem, ILogger log)\r\n {\r\n log.LogInformation($"C# Queue trigger function processed: {myQueueItem}");\r\n }\r\n }\r\n<\/pre>\n
g\u00f6r\u00fcld\u00fc\u011f\u00fc \u00fczere ‘QueueTrigger’ attribute’u ile i\u015faretlenmi\u015f ve ‘myqueue-items’ de\u011ferine sahip bir string parametre \u00fczerinden mesaj yakalanmaktad\u0131r.<\/p>\n
\u015eimdi bu trigger’\u0131 test edebilmek i\u00e7in \u00f6ncelikle ilgili Azure Queue Storage’da ‘myqueue-items’ isminde bir kuyruk olu\u015ftural\u0131m ve ard\u0131ndan trigger’\u0131 derleyip, \u00e7al\u0131\u015ft\u0131ral\u0131m.
\n $\"Azure$ <\/a>
\n $\"Azure$ <\/a>
\nG\u00f6r\u00fcld\u00fc\u011f\u00fc \u00fczere kuyru\u011fa verilen her bir mesaj neticede ilgili function taraf\u0131ndan string olarak kar\u015f\u0131lan\u0131p t\u00fcketilmektedir. \u0130sterseniz ilgili mesaj\u0131 bir entity ile kar\u015f\u0131layabilir ve otomatik olarak parse edip elde edebilirsiniz.<\/p>\n
\u015e\u00f6yle ki;<\/p>\n
\r\n public class Message\r\n {\r\n public string Key { get; set; }\r\n public string Value { get; set; }\r\n }\r\n<\/pre>\n
\r\n public static class Function1\r\n {\r\n [FunctionName("Function1")]\r\n public static void Run([QueueTrigger("myqueue-items", Connection = "")] Message message, ILogger log)\r\n {\r\n log.LogInformation($"C# Queue trigger function processed: {message.Key} - {message.Value}");\r\n }\r\n }\r\n<\/pre>\n
$\"Azure$ <\/a><\/p>\n
Ya da! \u0130\u00e7eri\u011fimizin ilk paragraflar\u0131nda belirtti\u011fim gibi mesaj\u0131 CloudQueueMessage t\u00fcr\u00fcnden kar\u015f\u0131layabilir ve gelen mesaja dair ekstradan detayl\u0131 bilgilerde edinebilirsiniz.<\/p>\n
\r\n public static class Function1\r\n {\r\n [FunctionName("Function1")]\r\n public static void Run([QueueTrigger("myqueue-items", Connection = "")] CloudQueueMessage message, ILogger log)\r\n {\r\n log.LogInformation($"Message : {message.AsString}");\r\n log.LogInformation($"Expiration Time : {message.ExpirationTime}");\r\n log.LogInformation($"Id : {message.Id}");\r\n log.LogInformation($"Dequeue Count : {message.DequeueCount}");\r\n log.LogInformation($"Pop Receipt : {message.PopReceipt}");\r\n }\r\n }\r\n<\/pre>\n
$\"Azure$ <\/a><\/p>\n
Queue Trigger \u0130le Input Blob Binding<\/h4>\n
\u015eimdi, Azure Queue Storage’a g\u00f6nderilen mesaj ile bir Blob Storage hesab\u0131na input binding ger\u00e7ekle\u015ftirerek, e\u015fle\u015fen dosyay\u0131 elde edip bilgilerini yazd\u0131ran bir Queue Trigger olu\u015ftural\u0131m.<\/p>\n
\r\n public static class Function1\r\n {\r\n [FunctionName("Function1")]\r\n public static void Run([QueueTrigger("myqueue-items", Connection = "")] string message, ILogger log,\r\n [Blob("files\/{queueTrigger}", FileAccess.Read, Connection = "")] CloudBlockBlob cloudBlockBlob)\r\n {\r\n log.LogInformation($"File Name : {cloudBlockBlob.Name}");\r\n log.LogInformation($"Blob Type : {cloudBlockBlob.BlobType}");\r\n }\r\n }\r\n<\/pre>\n
Bu yazd\u0131\u011f\u0131m\u0131z trigger’\u0131 incelersek e\u011fer; input binding yap\u0131lan Blob Storage i\u00e7erisindeki ‘files’ isimli container i\u00e7erisinde, queue’dan gelecek olan mesaj\u0131 temsil eden ‘queueTrigger’ keyword’\u00fc ile e\u015fle\u015fen blob’lar\u0131 elde edip bilgilerini okumam\u0131z\u0131 sa\u011flamaktad\u0131r. Sadece okuma i\u015flemi yap\u0131ld\u0131\u011f\u0131 i\u00e7in ‘FileAccess.Read’ olarak ayarlanm\u0131\u015ft\u0131r. Ayr\u0131ca bu binding ‘CloudBlockBlob’ yerine ‘Stream’ ya da ‘CloudBlobContainer’ olarak da al\u0131nabilirdi.<\/p>\n
Uygulamay\u0131 derleyip, \u00e7al\u0131\u015ft\u0131r\u0131rsak e\u011fer;
\n $\"Azure$ <\/a>
\n\u015feklinde verilen de\u011fere kar\u015f\u0131l\u0131k gelen blob’u elde edip, bilgilerini loglad\u0131\u011f\u0131n\u0131 g\u00f6zlemleyebilmekteyiz.<\/p>\n
\u0130lgilenenlerin faydalanmas\u0131 dile\u011fiyle…
\nSonraki yaz\u0131lar\u0131mda g\u00f6r\u00fc\u015fmek \u00fczere…
\n\u0130yi \u00e7al\u0131\u015fmalar dilerim…<\/p>\n","protected":false},"excerpt":{"rendered":"
Merhaba, Bu i\u00e7eri\u011fimizde Azure Functions yaz\u0131 serisinin son makalesi olan Queue Trigger \u00fczerine irdelemede bulunuyor olaca\u011f\u0131z. Queue Trigger Nedir? Azure Storage i\u00e7erisindeki herhangi bir queue servisindeki kuyru\u011fa mesaj geldi\u011finde tetiklenecek olan ve g\u00f6nderilen mesaj\u0131...<\/p>\n","protected":false},"author":1,"featured_media":17011,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[3121],"tags":[3696,3661,3758,3759,3695],"class_list":["post-17614","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-azure","tag-azure-function-queue-trigger","tag-azure-functions","tag-cloudqueuemessage","tag-input-blob-binding","tag-queue-trigger"],"amp_enabled":true,"_links":{"self":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/17614","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/comments?post=17614"}],"version-history":[{"count":29,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/17614\/revisions"}],"predecessor-version":[{"id":17649,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/17614\/revisions\/17649"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/media\/17011"}],"wp:attachment":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/media?parent=17614"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/categories?post=17614"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/tags?post=17614"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}