{"id":27475,"date":"2025-01-22T22:21:58","date_gmt":"2025-01-22T22:21:58","guid":{"rendered":"https:\/\/www.gencayyildiz.com\/blog\/?p=27475"},"modified":"2025-01-22T22:21:58","modified_gmt":"2025-01-22T22:21:58","slug":"nette-s3-eventleriyle-aws-lambdayi-tetikleyelim","status":"publish","type":"post","link":"https:\/\/www.gencayyildiz.com\/blog\/nette-s3-eventleriyle-aws-lambdayi-tetikleyelim\/","title":{"rendered":".NET’te S3 Event’leriyle AWS Lambda’y\u0131 Tetikleyelim"},"content":{"rendered":"

<\/div>\n

Merhaba,<\/p>\n

Bu i\u00e7eri\u011fimizde, AWS Lambda’y\u0131 S3 event’leri e\u015fli\u011finde nas\u0131l tetikleyebilece\u011fimizi inceliyor olaca\u011f\u0131z. Tabi bunu yaparken \u00f6nceden klavyeye alm\u0131\u015f oldu\u011fumuz AWS Lambda \u0130le Serverless Computing<\/a> ve AWS S3 \u0130le Dosya \u0130\u015flemleri Ger\u00e7ekle\u015ftirme<\/a> ba\u015fl\u0131kl\u0131 makalelerimizden de istifade edecek ve bunlardan event-driven yakla\u015f\u0131ma sahip bir sistem olu\u015fturmak i\u00e7in nas\u0131l entegrasyonun yap\u0131labilece\u011fini, ger\u00e7ek hayattan bir senaryo \u00fczerinden de\u011ferlendirmede bulunaca\u011f\u0131z. O halde buyurun ba\u015flayal\u0131m…<\/p>\n

Senaryo<\/h3>\n
\u00d6ncelikle senaryomuzun tahayy\u00fcl\u00fcn\u00fc ger\u00e7ekle\u015ftirerek ba\u015flayal\u0131m… <\/p>\n
Diyelim ki, bir Asp.NET Core web uygulamam\u0131z var ve kullan\u0131c\u0131lar taraf\u0131ndan daha \u00f6nce hi\u00e7 olmad\u0131\u011f\u0131 kadar resim y\u00fckleme eylemi ger\u00e7ekle\u015ftirilmektedir… Arka planda ise y\u00fcklenen her resim i\u00e7in depolama maliyetini optimize edebilmek maksad\u0131yla belli boyutland\u0131rma i\u015flemleri yap\u0131lmakta ve bir yerden sonra bu i\u015flemler uygulama a\u00e7\u0131s\u0131ndan bir darbo\u011faz olu\u015fturdu\u011fu i\u00e7in, bu resim i\u015flemeyi verimli bir \u015fekilde y\u00f6netme zorunlulu\u011fu ortaya \u00e7\u0131kmaktad\u0131r… \u0130\u015fte tam bu noktada bu g\u00f6rev i\u00e7in otomatik olarak \u00f6l\u00e7eklenen bir Serverless Lambda(AWS Lambda) asenkron olarak devreye girmekte ve y\u00fcklenecek resimleri S3’e g\u00f6ndererek bir yandan da resim i\u015fleme sorumlulu\u011fuyla ilgilenmektedir. Tabi burada AWS Lambda i\u015flevleri, S3 event’leri taraf\u0131ndan trigger edilmekte ve b\u00f6ylece zahmetsizce resimler \u00fczerinde gerekli i\u015flemler ger\u00e7ekle\u015ftirilmektedir.\n<\/div>\n
Umar\u0131m \u00e7\u00f6zmeye \u00e7al\u0131\u015faca\u011f\u0131m\u0131z sorunu tam olarak anlatabilmi\u015fimdir… Bu sorun, \u00f6zellikle y\u00fcksek trafikli uygulamalar i\u00e7in ge\u00e7erlidir. Keza, S3 event’leri e\u015fli\u011finde AWS Lambda entegrasyonunu izah edebilmek i\u00e7in de olduk\u00e7a ideal bir senaryo gibi g\u00f6z\u00fckmektedir.<\/p>\n
Ne in\u015fa edece\u011fiz?<\/h5>\n
Senaryomuz gere\u011fi in\u015fa edece\u011fimiz uygulaman\u0131n yap\u0131s\u0131ndan da bahsetmekte fayda g\u00f6rmekteyim. Bir resim\/image dosyas\u0131n\u0131 herhangi bir Amazon S3 bucket’\u0131na y\u00fckleyecek uygulama geli\u015ftirece\u011fiz. Bu ama\u00e7 do\u011frultusunda kullan\u0131c\u0131dan ald\u0131\u011f\u0131 resim dosyas\u0131n\u0131 S3 lokasyonuna y\u00fckleyecek olan minimal api teknolojisiyle geli\u015ftirilmi\u015f bir ortam sa\u011flayacak ve devam\u0131nda resim y\u00fcklendi\u011finde de S3 event notification sistemini i\u015fleyecek ve yeni y\u00fcklenen resmi getirip boyutland\u0131rma \u00e7al\u0131\u015fmas\u0131n\u0131 ger\u00e7ekle\u015ftirecek olan bir AWS Lambda uygulamas\u0131 geli\u015ftirilecektir. Ee haliyle notification k\u0131sm\u0131n\u0131n sa\u011fl\u0131kl\u0131 \u00e7al\u0131\u015fabilmesi i\u00e7in \u00f6ncelikle AWS Lambda ve S3 bucket k\u0131s\u0131mlar\u0131n\u0131 \u00f6nceden yap\u0131land\u0131rm\u0131\u015f olmam\u0131z gerekecektir. T\u00fcm bunlar\u0131n d\u0131\u015f\u0131nda resim i\u015fleme s\u00fcrecinde pop\u00fcler olan ImageSharp<\/a> paketinden istifade edece\u011fiz.<\/p>\n
Evet, haz\u0131rsak e\u011fer hadi ba\u015flayal\u0131m…<\/p>\n
Amazon S3 Bucket Olu\u015fturma<\/h3>\n
\u0130lk olarak \u00e7al\u0131\u015fmalar\u0131m\u0131za a\u015fa\u011f\u0131daki g\u00f6rseldeki gibi resimleri depolayaca\u011f\u0131m\u0131z example-image-storage<\/em> ad\u0131nda bir S3 bucket olu\u015fturarak ba\u015flayabiliriz. $\".NET'te$ <\/a><\/p>\n
Resim Y\u00fckleme API’sini Olu\u015fturma<\/h3>\n
Ard\u0131ndan resimleri bu S3 bucket’a y\u00fckleyecek olan minimal api projesini olu\u015fturabiliriz. Bunun i\u00e7in ben AWS.Image.Example.API<\/em> ad\u0131nda bir Asp.NET Core projesi olu\u015fturuyorum. Ve akabinde bu projede S3 i\u015flemleri i\u00e7in kullanaca\u011f\u0131m\u0131z a\u015fa\u011f\u0131daki k\u00fct\u00fcphanelerin y\u00fcklenmesini sa\u011fl\u0131yorum;
\n`Install-Package AWSSDK.S3<\/code> \nInstall-Package AWSSDK.Extensions.NETCore.Setup<\/code> \nVe devam\u0131nda ise a\u015fa\u011f\u0131daki gibi resim y\u00fckleme i\u015fleminin endpoint’ini olu\u015fturuyorum;<\/p>\n`
`\n`\r\nusing Amazon.S3;\r\nusing Amazon.S3.Model;\r\n\r\nvar builder = WebApplication.CreateBuilder(args);\r\n\r\nbuilder.Services.AddDefaultAWSOptions(builder.Configuration.GetAWSOptions());\r\nbuilder.Services.AddAWSService<IAmazonS3>();\r\n\r\nvar app = builder.Build();\r\n\r\napp.MapPost("\/image-upload", async (IFormFile file, IAmazonS3 amazonS3) =>\r\n{\r\n if (!file.ContentType.StartsWith("image\/"))\r\n return Results.BadRequest("Dosya ge\u00e7ersizdir. Yaln\u0131z resim dosyalar\u0131 desteklenmektedir.");\r\n\r\n PutObjectRequest request = new()\r\n {\r\n BucketName = "example-image-storage",\r\n Key = $"images\/{Path.GetFileName(file.FileName)}",\r\n InputStream = file.OpenReadStream()\r\n };\r\n\r\n request.Metadata.Add("Content-Type", file.ContentType);\r\n await amazonS3.PutObjectAsync(request);\r\n return Results.Ok($"Resim ba\u015far\u0131yla y\u00fcklenmi\u015ftir. | {Path.GetFileName(file.FileName)}");\r\n}).DisableAntiforgery();\r\n\r\napp.Run();\r\n<\/pre>\n<\/div>\nYapt\u0131\u011f\u0131m\u0131z bu \u00e7al\u0131\u015fmay\u0131 test edersek e\u011fer;<\/a>G\u00f6r\u00fcld\u00fc\u011f\u00fc \u00fczere endpoint’imiz ba\u015far\u0131yla \u00e7al\u0131\u015fmaktad\u0131r. S3 bucket’\u0131 da kontrol edelim;<\/a><\/p>\n Resim Boyutland\u0131rma Lambda’s\u0131n\u0131n Olu\u015fturulmas\u0131<\/h3>\nResimleri istenen S3 bucket’\u0131na y\u00fckleyecek bir API olu\u015fturdu\u011fumuza g\u00f6re art\u0131k gereksinimimiz a\u00e7\u0131s\u0131ndan resim boyutland\u0131rma servisini olu\u015fturabiliriz. Bunun i\u00e7in ayn\u0131 solution alt\u0131nda, ‘Sizing.Example’<\/em> ad\u0131nda yeni bir AWS Lambda Project<\/a> olu\u015ftural\u0131m.<\/a>Olu\u015fturulan bu lambda’ya ImageSharp k\u00fct\u00fcphanesini y\u00fckleyelim ve i\u00e7eri\u011fini a\u015fa\u011f\u0131daki gibi \u015fekillendirelim;<\/p>\n \n\r\npublic class Function\r\n{\r\n IAmazonS3 S3Client { get; set; }\r\n\r\n public Function()\r\n {\r\n S3Client = new AmazonS3Client();\r\n }\r\n\r\n public Function(IAmazonS3 s3Client)\r\n {\r\n this.S3Client = s3Client;\r\n }\r\n\r\n public async Task FunctionHandler(S3Event evnt, ILambdaContext context)\r\n {\r\n var eventRecords = evnt.Records ?? new List<S3Event.S3EventNotificationRecord>();\r\n foreach (var record in eventRecords)\r\n {\r\n var s3Event = record.S3;\r\n if (s3Event == null)\r\n {\r\n continue;\r\n }\r\n\r\n try\r\n {\r\n var bucketName = s3Event.Bucket.Name;\r\n var key = s3Event.Object.Key;\r\n var response = await S3Client.GetObjectAsync(bucketName, key);\r\n context.Logger.LogLine($"{key} orjinal resim boyutu : {response.ContentLength}");\r\n\r\n using (var image = Image.Load(response.ResponseStream))\r\n {\r\n int maxWidth = 500, maxHeight = 500;\r\n image.Mutate(x => x.Resize(new ResizeOptions\r\n {\r\n Mode = ResizeMode.Max,\r\n Size = new Size(maxWidth, maxHeight)\r\n }));\r\n\r\n using (MemoryStream stream = new MemoryStream())\r\n {\r\n image.Save(stream, new SixLabors.ImageSharp.Formats.Jpeg.JpegEncoder());\r\n context.Logger.LogLine($"{key} boyutland\u0131r\u0131lm\u0131\u015f resim boyutu : {stream.Length}");\r\n var resizedIamgesPath = $"resized-images\/{key.Replace("images\/", "")}";\r\n var uploadRequest = new PutObjectRequest\r\n {\r\n BucketName = bucketName,\r\n Key = resizedIamgesPath,\r\n InputStream = stream\r\n };\r\n await this.S3Client.PutObjectAsync(uploadRequest);\r\n context.Logger.LogLine($"Resim yeniden boyutland\u0131r\u0131lm\u0131\u015ft\u0131r.");\r\n }\r\n }\r\n \/\/Orjinal resmi silelim\r\n await this.S3Client.DeleteObjectAsync(bucketName, s3Event.Object.Key);\r\n context.Logger.LogLine($"Orjinal resim silinmi\u015ftir. {s3Event.Object.Key}");\r\n }\r\n catch (Exception e)\r\n {\r\n context.Logger.LogError(e.Message);\r\n context.Logger.LogError(e.StackTrace);\r\n throw;\r\n }\r\n }\r\n }\r\n}\r\n<\/pre>\n<\/div>\nYukar\u0131daki kod blo\u011funu incelersek e\u011fer AWS S3 \u00fczerindeki belirtti\u011fimiz bucket’a y\u00fcklenen resimleri yeniden boyutland\u0131rma i\u015flemi y\u00fcr\u00fct\u00fclmektedir. Burada baz\u0131 kodlar\u0131n i\u015flevselli\u011finden bahsetmemizin faydal\u0131 olaca\u011f\u0131 kanaatindeyim. Misal olarak; evnt.Records<\/code>, S3Event nesnesindeki t\u00fcm event kay\u0131tlar\u0131n\u0131 getirmektedir. Yani tetikleyici olaylar\u0131n listesidir diyebiliriz. record.S3<\/code> ise her bir S3EventNotificationRecord<\/code> i\u00e7indeki o olaya ait S3 bilgilerini temsil etmektedir. \u00d6rne\u011fin, hangi bucket’a hangi dosyan\u0131n y\u00fcklendi\u011fi gibi bilgiler bu nesne \u00fczerinden al\u0131n\u0131r. Son olarak s3Event.Object.Key<\/code> komutunu izah edersek e\u011fer, bu da dosyan\u0131n S3 i\u00e7indeki yolunu temsil etmektedir. \u0130\u015fte bu bilgiler e\u015fli\u011finde bizler S3 bucket’a y\u00fcklenen resim dosyas\u0131 \u00fczerinde gerekli i\u015flemleri ger\u00e7ekle\u015ftiriyor ve orjinal dosyay\u0131 silerek, boyutland\u0131r\u0131lm\u0131\u015f haliyle s\u00fcreci tamaml\u0131yoruz.<\/p>\nEvet, art\u0131k lambda function’\u0131m\u0131z\u0131 olu\u015fturdu\u011fumuza g\u00f6re AWS’ye publish edebiliriz.<\/a>G\u00f6r\u00fcld\u00fc\u011f\u00fc \u00fczere SizingExample<\/em> isminde bir lambda function olu\u015fturuyoruz.<\/a>Bu a\u015famada rol olarak AWSLambdaExecute<\/em>‘u se\u00e7menizi tavsiye ederim. B\u00f6ylece Cloudwatch’a log atabilmeniz i\u00e7in temel izinleri elde etmi\u015f olacaks\u0131n\u0131z.<\/p>\n Ve nihai olarak bu \u015fekilde lambda’y\u0131 publish edelim…<\/a><\/p>\n S3 Eri\u015fimi \u0130\u00e7in Lambda \u0130zinlerinin G\u00fcncellenmesi<\/h3>\nGeli\u015ftirdi\u011fimiz lambda taraf\u0131ndan S3 servisine eri\u015fip gerekli resim i\u015flemlerinin ger\u00e7ekle\u015ftirilebilmesi i\u00e7in do\u011fal olarak bir tak\u0131m izinlere ihtiyac\u0131m\u0131z olacakt\u0131r. Bu izinlerin d\u00fczenlenebilmesi i\u00e7in lambda servisi \u00fczerinden olu\u015fturdu\u011fumuz SizingExample<\/em> isimli lambda’y\u0131 a\u00e7al\u0131m ve a\u015fa\u011f\u0131daki g\u00f6rselde oldu\u011fu gibi lambda rol\u00fcne t\u0131klayarak eri\u015fim politikalar\u0131n\u0131 d\u00fczenleyelim.<\/a>Ard\u0131ndan Permissions policies<\/em> k\u0131sm\u0131ndan ‘Add policies’ -> ‘Attach policies’ diyerek lambda’ya yeni eri\u015fim izni tan\u0131mlayal\u0131m.<\/a>Burada AmazonS3FullAccess<\/code> se\u00e7erek yola devam edebiliriz.<\/a>Evet, art\u0131k lambda taraf\u0131ndan S3 eri\u015fimi verildi\u011fine g\u00f6re AWS Lambda’y\u0131 S3 Event’leriyle tetikleyebiliriz.<\/p>\n AWS Lambda’y\u0131 S3 Event’leriyle Tetikleme<\/h3>\nArt\u0131k her \u015fey yerli yerinde oldu\u011funa g\u00f6re, yapbozun son par\u00e7as\u0131n\u0131 yerle\u015ftirebilir ve S3 bucket’\u0131 alt\u0131ndaki ‘images’<\/em> klas\u00f6r\u00fcne yeni bir resim y\u00fcklendi\u011fi taktirde lambda’m\u0131z\u0131 tetikleyebiliriz.<\/p>\nBunun i\u00e7in de yine lambda \u00fczerinden a\u015fa\u011f\u0131daki g\u00f6rselde oldu\u011fu gibi ‘Configuration’ -> ‘Triggers’ sekmesine gelerek yeni bir trigger eklememiz gerekmektedir.<\/a>Trigger’la ilgili ayarlar\u0131 a\u015fa\u011f\u0131daki g\u00f6rseldeki gibi yap\u0131land\u0131ral\u0131m;<\/a>Ve trigger’\u0131 olu\u015ftural\u0131m.<\/a>\u0130\u015fte bu kadar… Bu yapt\u0131\u011f\u0131m\u0131z i\u015flem neticesinde S3 bucket’ta ki ‘\/images’ yoluna bir resim y\u00fcklendi\u011fi taktirde bu trigger sayesinde, S3Event meta verisi e\u015fli\u011finde lambda tetiklenecektir. Vee gerekli resim boyutland\u0131rma i\u015flemini lambda halledecektir.<\/p>\n Test Edelim…<\/h4>\n\u015eimdi S3 bucket’a olu\u015fturdu\u011fumuz API arac\u0131l\u0131\u011f\u0131yla resim dosyas\u0131n\u0131 g\u00f6nderelim ve s\u00fcreci CloudWatch loglar\u0131ndan takip edelim;<\/a>G\u00f6r\u00fcld\u00fc\u011f\u00fc \u00fczere resim orjinal haliyle y\u00fckleniyor, yeniden boyutland\u0131r\u0131l\u0131yor ve orjinali silinerek yeni hali ‘resized-images\/’<\/em> path’ine koyuluyor.<\/a><\/p>\n Hata Durumlar\u0131nda \u0130se…<\/h3>\nE\u011fer ki yap\u0131lan bu i\u015flem s\u00fcrecinde bir ba\u015far\u0131s\u0131zl\u0131k durumu s\u00f6z konusu olursa AWS Lambda maksimum 6 saat i\u00e7erisinde 2 kez deneme ger\u00e7ekle\u015ftirecektir. E\u011fer ki bu denemelerden bir netice al\u0131namazsa o dosyaya kar\u015f\u0131 olu\u015fturulan event kaybolacakt\u0131r. Bu duruma dair t\u00fcm yap\u0131land\u0131rmalar\u0131 a\u015fa\u011f\u0131daki g\u00f6rselde oldu\u011fu gibi lambda’n\u0131n ‘Configuration’ -> ‘Asynchronous invocation’ k\u0131sm\u0131ndan yapabilirsiniz.<\/a>Bu durumu engelleyebilmek i\u00e7in Dead Letter Queue (DLQ) olu\u015fturarak \u00f6nlem alabilir ve yeniden denemeden sonra ba\u015far\u0131s\u0131z olan t\u00fcm event’leri belirtilen DLQ’ya ta\u015f\u0131yarak, sonradan bu kuyruk \u00fczerinden resimleri i\u015fleyebilirsiniz.<\/p>\n Nihai olarak; \nB\u00f6ylece S3 bucket’a y\u00fcklenen bir dosya \u00fczerinden AWS Lambda’n\u0131n nas\u0131l tetiklenebilece\u011fini(trigger), dosya i\u015fleme mant\u0131\u011f\u0131n\u0131 ana uygulamadan ay\u0131rarak nas\u0131l uygulanabilece\u011fini ve genel sistem performans\u0131n\u0131 iyile\u015ftirmenin temiz bir yolunu hep beraber tecr\u00fcbe etmi\u015f bulunuyoruz.<\/p>\n \u0130lgilenenlerin faydalanmas\u0131 dile\u011fiyle… \nSonraki yaz\u0131lar\u0131mda g\u00f6r\u00fc\u015fmek \u00fczere… \n\u0130yi \u00e7al\u0131\u015fmalar…<\/p>\n Not : \u00d6rnek \u00e7al\u0131\u015fmaya a\u015fa\u011f\u0131daki github adresinden eri\u015febilirsiniz. \nhttps:\/\/github.com\/gncyyldz\/AWS.Image.Example.API<\/a><\/p>\n","protected":false},"excerpt":{"rendered":" Merhaba, Bu i\u00e7eri\u011fimizde, AWS Lambda’y\u0131 S3 event’leri e\u015fli\u011finde nas\u0131l tetikleyebilece\u011fimizi inceliyor olaca\u011f\u0131z. Tabi bunu yaparken \u00f6nceden klavyeye alm\u0131\u015f oldu\u011fumuz AWS Lambda \u0130le Serverless Computing ve AWS S3 \u0130le Dosya \u0130\u015flemleri Ger\u00e7ekle\u015ftirme ba\u015fl\u0131kl\u0131 makalelerimizden de...<\/p>\n","protected":false},"author":1,"featured_media":27502,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[5206,5085,2739,4692,4730],"tags":[4691,4739,5208,5106,5107,5207],"class_list":["post-27475","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-net","category-net-9","category-net-core","category-amazon-s3","category-aws","tag-amazon-s3","tag-aws-lambda","tag-aws-lambda-trigger","tag-dead-letter-queue","tag-dlq","tag-s3-event"],"amp_enabled":true,"_links":{"self":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/27475","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=27475"}],"version-history":[{"count":8,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/27475\/revisions"}],"predecessor-version":[{"id":27503,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/posts\/27475\/revisions\/27503"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/media\/27502"}],"wp:attachment":[{"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/media?parent=27475"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/categories?post=27475"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.gencayyildiz.com\/blog\/wp-json\/wp\/v2\/tags?post=27475"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}