Opis koncepcyjny proponowanego rozwi\u0105zania<\/h2>\n\n\n\n
Platforma chmurowa Azure daje wiele mo\u017cliwo\u015bci. Jedn\u0105 z nich jest tworzenie niewielkich aplikacji w szybki spos\u00f3b, jednocze\u015bnie pozwalaj\u0105c na ich bardzo \u0142atw\u0105 i wygodn\u0105 integracj\u0119. Wobec tego przyjrzyjmy si\u0119 proponowanemu rozwi\u0105zaniu opartemu o komponenty Azure (Ryc. 1).<\/p>\n\n\n\n
![\"Ryc.](\"https:\/\/sii.pl\/blog\/wp-content\/uploads\/2022\/01\/Ryc.1-1024x138-1.png\")
<\/a>Najwa\u017cniejszym elementem jest w tym przypadku Azure LogicApp<\/strong>, kt\u00f3ry ma trzy podstawowe zadania:<\/p>\n\n\n\n Azure FunctionApp udost\u0119pnia endpoint pozwalaj\u0105cy na pobranie zapisanego wcze\u015bniej bloba w formie tekstowej.<\/p>\n\n\n\n Pora przyjrze\u0107 si\u0119 szczeg\u00f3\u0142om technicznym. Opisz\u0119 krok po kroku proces tworzenia aplikacji. Dla uproszczenia, wy\u0142\u0105czaj\u0105c jednak kroki zwi\u0105zane z tworzeniem samych zasob\u00f3w, gdy\u017c istnieje wiele tutoriali, jak poradzi\u0107 sobie z tym tematem. Znajdziemy je na przyk\u0142ad w oficjalnej dokumentacji Microsoftu:<\/p>\n\n\n\n Dodatkowo, w ko\u0144cowej cz\u0119\u015bci artyku\u0142u opisz\u0119 procedur\u0119 deploymentu z u\u017cyciem ARM template odzwierciedlaj\u0105cego stworzone zasoby. Pozwoli to na szybkie odtworzenie opisanego rozwi\u0105zania bez konieczno\u015bci \u201ewyklikiwania\u201d wszystkiego w portalu.<\/p>\n\n\n\n Po utworzeniu LogicApp przejd\u017amy do implementacji. Wybierzmy utworzony zas\u00f3b LogicApp. Nast\u0119pnie z menu po lewej w sekcji Development Tools kliknijmy Logic App Designer oraz, z dost\u0119pnych opcji, Blank Logic App. Pierwszym krokiem jest decyzja, co b\u0119dzie wyzwala\u0142o wykonanie utworzonej funkcji (Ryc. 2).<\/p>\n\n\n\n Dost\u0119pnych opcji s\u0105 setki, natomiast w naszym przypadku skorzystamy z connectora Office 365 Outlook i akcji \u201eWhen a new email arrives in a shared mailbox (V2)\u201d. Wybra\u0142em shared mailbox, poniewa\u017c ta skrzynka po ustawieniu odpowiednich uprawnie\u0144 mo\u017ce by\u0107 dost\u0119pna dla ka\u017cdego cz\u0142onka zespo\u0142u, u\u0142atwiaj\u0105c wsp\u00f3ln\u0105 prac\u0119.<\/p>\n\n\n\n Konfiguracja connectora powinna by\u0107 nast\u0119puj\u0105ca (Ryc. 3):<\/p>\n\n\n\n Original Mailbox Address jest adresem naszej skrzynki wsp\u00f3\u0142dzielonej. Inne opcje pozwalaj\u0105 na filtrowanie wiadomo\u015bci e-mail. Wed\u0142ug ustawie\u0144, skrzynka sprawdzana jest co 20 sekund. Po wprowadzeniu parametr\u00f3w, musimy uwierzytelni\u0107 dost\u0119p do skrzynki poprzez zalogowanie si\u0119. Warto wspomnie\u0107, \u017ce po skorzystaniu z connector\u00f3w w naszej Resource Group zostan\u0105 stworzone dodatkowe zasoby typu API Connection.<\/p>\n\n\n\n Otrzymywane wiadomo\u015bci e-mail powinny by\u0107 mo\u017cliwe do jednoznacznego zidentyfikowania, wobec tego za\u0142\u00f3\u017cmy, \u017ce w tytule wiadomo\u015bci znajduje si\u0119 unikalne OrderId. U\u017cyjemy go r\u00f3wnie\u017c jako nazwy pliku zapisanego w Blob Storage.<\/p>\n\n\n\n Dodajmy wobec tego krok w LogicApp, pozwalaj\u0105cy na zainicjalizowanie zmiennej warto\u015bci\u0105 tego Id. Wybierzmy kolejno New Step, Variables, Initialize variable (Ryc. 4).<\/p>\n\n\n\n Jako warto\u015b\u0107 wyra\u017cenia Expression podajmy:<\/p>\n\n\n Jest to wyra\u017cenie pozwalaj\u0105ce na wyszukanie w temacie wiadomo\u015bci e-mail ci\u0105gu znak\u00f3w \u201eORDERID: \u201d oraz pobranie kolejnych 10 znak\u00f3w, kt\u00f3re b\u0119d\u0105 stanowi\u0107 w\u0142a\u015bnie parametr orderId.<\/p>\n\n\n Jest to wyra\u017cenie pozwalaj\u0105ce na wyszukanie w temacie wiadomo\u015bci e-mail ci\u0105gu znak\u00f3w \u201eORDERID: \u201d oraz pobranie kolejnych 10 znak\u00f3w, kt\u00f3re b\u0119d\u0105 stanowi\u0107 w\u0142a\u015bnie parametr orderId.<\/p>\n\n\n\n Kolejny krok, kt\u00f3ry powinni\u015bmy doda\u0107, to po\u0142\u0105czenia do Azure Storage Account: New Step, Azure Blob Storage, Create New Blob (Ryc. 5).<\/p>\n\n\n\n Nast\u0119pnie skonfigurujmy to po\u0142\u0105czenie (Ryc. 6):<\/p>\n\n\n\n Parametry to:<\/p>\n\n\n\n Account Name oraz Access Key mo\u017cemy odnale\u017a\u0107 we wcze\u015bniej stworzonym Storage Account (Ryc. 7):<\/p>\n\n\n\n Po uzyskaniu po\u0142\u0105czenia ze Storage Account musimy zaimplementowa\u0107 akcj\u0119 tworzenia bloba (Ryc. 8):<\/p>\n\n\n\n Parametry:<\/p>\n\n\n\n Musimy mie\u0107 r\u00f3wnie\u017c pewno\u015b\u0107, \u017ce skonfigurowany kontener istnieje, wobec czego dodajmy go w Storage Account (Ryc. 9). Niestety, na chwil\u0119 obecn\u0105 API Azure nie pozwala na tworzenie kontener\u00f3w z poziomu LogicApp. Mo\u017cna to jednak zrobi\u0107 np. poprzez wywo\u0142anie FunctionApp, kt\u00f3ra to zadanie jest w stanie wykona\u0107. Automatyzacja tego procesu jest jednak poza zakresem niniejszego artyku\u0142u.<\/p>\n\n\n\n W tym momencie jeste\u015bmy gotowi do przetestowania zapisu wiadomo\u015bci e-mail poprzez wys\u0142anie maila na wcze\u015bniej utworzon\u0105 skrzynk\u0119 (pami\u0119tajmy jednak, aby tytu\u0142 zawiera\u0142 wyra\u017cenie \u201eORDERID: \u201d). Wiadomo\u015b\u0107 powinna znale\u017a\u0107 si\u0119 we wcze\u015bniej utworzonym kontenerze emails.<\/p>\n\n\n\n Poprawne (b\u0105d\u017a nie) wykonanie naszej aplikacji mo\u017cemy podgl\u0105dn\u0105\u0107 w sekcji Overview stworzonej LogicApp. Klikaj\u0105c w konkretny wiersz, uzyskamy dost\u0119p do szczeg\u00f3\u0142\u00f3w wykonania \u2013 jest to r\u00f3wnie\u017c spos\u00f3b na debuggowanie (Ryc. 10).<\/p>\n\n\n\n Na chwil\u0119 obecn\u0105 mamy zapisan\u0105 wiadomo\u015b\u0107 w Azure Storage Account, natomiast chcieliby\u015bmy w \u0142atwy i szybki spos\u00f3b, m\u00f3c t\u0105 wiadomo\u015b\u0107 odczyta\u0107 w naszej solucji z testami E2E (w solucji testowej wystarczy wykona\u0107 najzwyklejsze zapytanie HTTP GET). Wobec tego stw\u00f3rzmy FunctionApp, kt\u00f3re posiada\u0107 b\u0119dzie nast\u0119puj\u0105ce funkcjonalno\u015bci:<\/p>\n\n\n\n W Visual Studio stw\u00f3rzmy now\u0105 solucj\u0119 oraz dodajmy do niej projekt Azure Functions (nast\u0119pnie wybierzmy .NET Core 3 LTS jako framework aplikacji oraz Http Trigger jako spos\u00f3b wyzwolenia akcji) (Ryc. 11):<\/p>\n\n\n\n Kod funkcji, umo\u017cliwiaj\u0105cy pobranie wiadomo\u015bci e-mail z bloba, wygl\u0105da nast\u0119puj\u0105co:<\/p>\n\n\n Natomiast kod funkcji odpowiedzialnej za czyszczenie kontenera jest nast\u0119puj\u0105cy (tym razem jest to funkcja wyzwalana poprzez Timer Trigger konfigurowany przy pomocy wyra\u017cenia CRON):<\/p>\n\n\n My\u015bl\u0119, \u017ce kod obydwu funkcji jest samoopisuj\u0105cy si\u0119, wi\u0119c nie b\u0119d\u0119 zag\u0142\u0119bia\u0142 si\u0119 w jego szczeg\u00f3\u0142y. Pe\u0142ne rozwi\u0105zanie mo\u017cna znale\u017a\u0107 na moim GitHubie<\/a>.<\/p>\n\n\n\n Ostatnim krokiem jest stworzenie Publish Profile oraz deploy FunctionApp z Visual Studio do Azure. Kliknijmy prawym klawiszem na projekt zawieraj\u0105cy funkcje i wybierzmy Publish oraz kolejno Azure, Azure FunctionApp (Windows) i w okienku konfiguracyjnym Publish zaznaczmy nasz\u0105 subskrypcj\u0119, Resource Group oraz stworzon\u0105 wcze\u015bniej FunctionApp.<\/p>\n\n\n\n Kliknijmy Finish, co pozwoli nam utworzy\u0107 Publish Profile. Wtedy pozostaje ju\u017c sam deploy, kt\u00f3ry b\u0119dzie mia\u0142 miejsce po klikni\u0119ciu przycisku Publish. Przy pomocy narz\u0119dzia Postman, kt\u00f3re pozwala na wykonanie zapyta\u0144 m. in. do endpoint\u00f3w FunctionApp, zweryfikujmy poprawno\u015b\u0107 dzia\u0142ania aplikacji (Ryc. 12):<\/p>\n\n\n\nRozwi\u0105zanie<\/h2>\n\n\n\n
Implementacja<\/h3>\n\n\n\n
<\/a>Konfiguracja connectora<\/h3>\n\n\n\n
<\/a>Inicjalizacja zmiennej<\/h3>\n\n\n\n
<\/a>\nsubstring(triggerBody()?['Subject'], add(9, lastIndexOf(triggerBody()?['Subject'], 'ORDERID: ')), 10)\n<\/pre><\/div>\n\n\n
\nsubstring(triggerBody()?['Subject'], add(9, lastIndexOf(triggerBody()?['Subject'], 'ORDERID: ')), 10)\n<\/pre><\/div>\n\n\n
Po\u0142\u0105czenie do Azure Storage Account<\/h3>\n\n\n\n
<\/a><\/a><\/a>Implementacja akcji tworzenia bloba<\/h3>\n\n\n\n
<\/a><\/a>Przetestowanie dzia\u0142ania aplikacji<\/h3>\n\n\n\n
<\/a>Odczytywanie wiadomo\u015bci w solucji z testami E2E<\/h3>\n\n\n\n
<\/a>Kod funkcji pozwalaj\u0105cy na pobranie wiadomo\u015bci e-mail<\/h3>\n\n\n\n
\n[FunctionName("get-email")]\n public async Task<IActionResult> Run(\n [HttpTrigger(AuthorizationLevel.Function, "get", Route = null)] HttpRequest req,\n [Blob(Constants.EmailContainerName, FileAccess.Read)] CloudBlobContainer myBlobContainer,\n ILogger log,\n IBinder binder)\n {\n log.LogInformation("C# HTTP trigger GetEmail function starts processing a request.");\n await myBlobContainer.CreateIfNotExistsAsync();\n string orderId = req.Query["orderid"];\n if (string.IsNullOrEmpty(orderId))\n return new BadRequestObjectResult("Please pass an orderId on the query string");\n var result = await _blobRepository.ReadEmail(binder, orderId);\n return new OkObjectResult(result);\n }\n<\/pre><\/div>\n\n\n\n[FunctionName("cleanup-emails")]\n public static async Task Run([TimerTrigger("0 50 * * * *")] TimerInfo myTimer,\n [Blob(Constants.EmailContainerName, FileAccess.ReadWrite)] CloudBlobContainer myBlobContainer,\n ILogger log)\n {\n log.LogInformation($"{nameof(CleanupEmails)} Timer trigger function executed at: {DateTime.Now}");\n\n await myBlobContainer.CreateIfNotExistsAsync();\n\n BlobContinuationToken blobContinuationToken = null;\n var blobList = await myBlobContainer.ListBlobsSegmentedAsync(blobContinuationToken);\n var cloudBlobList = blobList.Results\n .Select(blb => blb as ICloudBlob)\n .Where(blb => blb.Properties.LastModified < DateTime.Now.AddHours(-1));\n\n foreach (var item in cloudBlobList)\n {\n await item.DeleteIfExistsAsync();\n }\n }\n<\/pre><\/div>\n\n\nOstatnie kroki<\/h3>\n\n\n\n