Upskilling to proces ciągłego doskonalenia swoich umiejętności zawodowych. W dynamicznie zmieniającym się świecie technologii, umiejętność szybkiego dostosowania się do nowych wymagań jest kluczowa do osiągnięcia sukcesu. W artykule dla Inhire przedstawiamy praktyczne podejście, które można wykorzystać w procesie upskillingu. W Silky Coders wiemy, że kursy online, szkolenia, certyfikacje czy udział w projektach to tylko pierwszy krok do poszerzenia swoich kompetencji. Ale to nie wszystko! W artykule podkreślamy również ważność podejmowania nowych wyzwań i nauki w praktyce, co pozwala na zdobycie praktycznego doświadczenia. Dlaczego to takie ważne? Bo teoria to jedno, ale umiejętność praktycznego zastosowania w pracy to już zupełnie inna sprawa.
Program Lojalnościowy Sinsay Club to projekt omnichannelowy dedykowany klientom Sinsay we wszystkich kanałach sprzedażowych, dotykający wielu zespołów i systemów. W ramach tego projektu powołano dedykowany zespół backendowy SiStar, włączając w to zespoły Sinsay Mobile, CSI, Rmax, P, PP, EA, GPOS. Oczywiście nie zabrakło wsparcia DevOpsów, analityków biznesowych i systemowych, testerów oraz działów prawnych.
Aby zapewnić skalowalność rozwiązania, wykorzystaliśmy silnik Kubernetes. Dzięki tej technologii jesteśmy w stanie zapewnić obsługę zarówno w codziennych działaniach, jak i w pikach, które pojawiają się podczas dużych promocji. Kluczowym wymaganiem biznesowym było osiągnięcie krótkiego czasu wprowadzenia na rynek, co udało się zrealizować dzięki wykorzystaniu języka PHP i frameworka Symfony. Wydajność aplikacji osiągnięto dzięki wykorzystaniu najnowszych wersji języka PHP oraz takich technologii jak RabbitMQ, Kafka, Redis i MongoDB.
Proces tworzenia całego rozwiązania był dosyć skomplikowany, przede wszystkim z powodu omnichanelowości projektu i związanej z nią ilości osób, działów i procesów zaangażowanych w jego wytwarzanie. Program Lojalnościowy dotyka procesów sprzedażowych organizacji, dlatego szczególnie ważne było testowanie wytworzonych funkcjonalności. Kwestie związane z User Experience również nie ułatwiały procesu – poprawki po badaniach nanoszono zarówno na procesy biznesowe, jak i na kod aplikacji.
Forcom to dostawca oprogramowania, który zajmuje się logiką promocji związaną z programem lojalnościowym. Jest to ekosystem aplikacji, do których łączymy się za pomocą API poprzez protokół HTTP.
Największym wyzwaniem były obecne procesy biznesowe w LPP, które są mocno zindywidualizowane i podyktowane proklienckim podejściem. Wpięcie się w istniejące procesy i zapewnienie kompatybilności pomiędzy procesami zrealizowanymi przez dostawcę zewnętrznego stanowiło zdecydowanie największe wyzwanie.
Innowacyjność, adaptacja do zmieniających się trendów i potrzeb klientów są kluczowe do osiągnięcia sukcesu w dynamicznie rozwijającym się świecie biznesu.
Aplikacja Sinsay zadebiutowała w kwietniu 2022 roku i w ciągu niespełna roku znalazła się wśród najczęściej pobieranych aplikacji mobilnych. Kluczowym czynnikiem sukcesu aplikacji jest stała obserwacja rynku i dostosowywanie oferty do potrzeb klientek/klientów. Nasze zespoły pracują nad personalizacją oferty oraz zwiększaniem wygody zakupów poprzez usprawnienie procesów płatności i dostaw.
Strategia Sinsay jest zgodna z trendami obecnymi na rynku, gdzie aplikacje mobilne zyskują na popularności, a konsumenci coraz chętniej dokonują zakupów online. Dzięki ciągłej obserwacji rynku i dostosowywaniu oferty do potrzeb klientek, Sinsay utrzymuje swoją pozycję na rynku i przyciąga nowych klientów. Więcej o aplikacji Sinsay w artykule na forbes.pl opowiadają Kamil Wiśniowski – Enterprise Architect , Przemysław Wiśniewski – Senior Product Owner, Karol Gąsienica – Senior PHP Developer i Karol Naruszewicz – Senior Scrum Master.
W naszym wpisie na Inhire.io przedstawiamy częsty problem rotacji pracowników w branży IT, który może generować wiele trudności dla firm, w tym koszty związane z rekrutacją i szkoleniem nowych pracowników oraz spadek wydajności pracy.
Jako rozwiązanie na tę sytuację proponujemy skupienie się na budowaniu kultury organizacyjnej, która zapewni zadowolenie pracowników i zwiększy ich zaangażowanie. Kultura organizacyjna powinna być oparta na wartościach, takich jak zaufanie, otwartość i szacunek. W naszej praktyce stawiamy na rozwój kariery pracowników i ciągłe doskonalenie poprzez szkolenia i udział w projektach.
To wspaniała inicjatywa dzielenia się wiedzą przez zespół Data Science! Udostępnienie aktualizowanej książki o Data Science jest nie tylko korzystne dla studentów na Politechnice Gdańskiej, ale również dla wszystkich, którzy interesują się tą dziedziną i chcą rozwijać swoje umiejętności.
W obecnych czasach wiedza na temat uczenia maszynowego i analizy danych jest bardzo poszukiwana, a Data Science staje się coraz ważniejszym narzędziem w biznesie. Dlatego tak ważne jest, aby takie materiały były dostępne dla szerokiego grona ludzi, którzy chcą się rozwijać.
Aktualizacja książki o Data Science to doskonały sposób na utrzymywanie wiedzy na bieżąco. Udostępnienie konkretnych przykładów z kodem pozwala lepiej zrozumieć i zapamiętać pojęcia, a to z kolei ułatwia ich stosowanie w praktyce. Dzięki temu każdy, kto zechce skorzystać z tej publikacji, będzie miał szansę poszerzyć swoje umiejętności i wiedzę na temat Data Science.
Podsumowując, publikacja książki o Data Science jest doskonałym przykładem na to, jak ważne jest dzielenie się wiedzą w dzisiejszych czasach. To nie tylko przyczynia się do zwiększenia ilości ludzi, którzy posiadają wiedzę na temat tej dziedziny, ale również do jej rozwoju i popularyzacji.
Ekspansja na nowy rynek nie byłaby możliwa bez zaangażowania i współpracy zespołów LPP S.A., LPP Logistics i Silky Coders, które przez wiele miesięcy przygotowywały się do tego dnia.
Wdrożyliśmy wiele naszych aplikacji i procesów, w tym:
GPOS,
Store Vision,
terminale oparte na systemie Android,
RMS,
sprzedaż realizowana w modelu fiskalizacji online,
nowe obiegi dokumentów dla księgowości.
Nowy rynek zawsze stanowi ogromne wyzwanie, związane z koniecznością stosowania nowych rozwiązań fiskalnych, terminali oraz procesów dla pracowników, jednakże nasze zespoły, jak zawsze, dały z siebie wszystko, co pozwoliło uzyskać sukces już na starcie!
W każdym z systemów, obsługujących duży ruch sieciowy, w pewnym momencie spotykamy się z ograniczeniami komunikacji synchronicznej. W ciągu dnia zdarzają się duże, przejściowe wzrosty ruchu, które możemy rozłożyć na większą liczbę instancji systemu, co może okazać się zbędne, są bowiem sprytniejsze rozwiązania.
Nie wszystkie żądania muszą być przetworzone dokładnie w tym samym momencie. Większość z nich może poczekać na swoją kolej i będzie to jak najbardziej akceptowalne z biznesowego punktu widzenia – dzięki temu zmniejszą się chociażby problemy z wydajnością oraz infrastrukturą obsługiwanego przez nas systemu. Jak to osiągnąć? Warto skorzystać z systemu kolejkowego, a o jego funkcjonowaniu na konkretnym przykładzie opowiemy w tym artykule.
Gdy komunikacja synchroniczna nie wystarcza – kolejki
Kiedy już nadejdzie ten moment, w którym przetwarzanie synchroniczne przestanie być wydajne, trzeba znaleźć rozwiązanie rodzącego się problemu. Jedną z najpopularniejszych opcji jest wprowadzenie komunikacji asynchronicznej i zastosowanie kolejek. A czym właściwie są kolejki?
http://www.quickmeme.com/meme/3qdzk7
Kolejka to abstrakcyjny typ danych, który przechowuje uporządkowaną, liniową sekwencję elementów. Można to opisać jako strukturę FIFO (first in, first out) – pierwszy element, który zostanie dodany do kolejki, będzie pierwszym, który ją opuści. Taką kolejkę można przyrównać do zwykłej kolejki w sklepie lub na koncercie, gdzie pierwsza osoba, która w niej staje, będzie jako pierwsza obsłużona po czym z niej wychodzi. Proste i… sprawdza się.
Obsługa kolejek, czyli jakie wybrać narzędzia?
Uzbrojeni w kluczową wiedzę o kolejkach, w następnym kroku poszukujemy narzędzia do ich obsługi. Możemy je oczywiście napisać sami, ale o wiele lepiej jest skorzystać z istniejących i sprawdzonych rozwiązań. Dwa najpopularniejsze, dedykowane pod obsługę kolejek to Apache Kafka oraz RabbitMQ. W jednym z projektów zdecydowaliśmy się na wybór RabbitMQ, między innymi ze względu na jeden z driverów architektonicznych – w tym przypadku są to ograniczenia projektowe. Ponadto Deweloperzy z Zespołu znali najlepiej właśnie to rozwiązanie i biorąc pod uwagę optymalizację czasu pracy, miało dla nas najniższy próg wejścia. Czym zatem jest wspomniane RabbitMQ?
RabbitMQ – broker wiadomości
RabbitMQ to broker wiadomości – pośrednik w komunikacji. Opiera się na protokole AMQP. Posiada oficjalne biblioteki klienckie napisane w wielu językach, takich jak: Java, Python czy też PHP. RabbitMQ to lekkie i niezwykle wydajne narzędzie, które wspomaga komunikację w systemach rozproszonych.
Poszczególne podsystemy w naszej aplikacji mogą komunikować się ze sobą za pomocą RabbitMQ z użyciem mechanizmu wiadomości (np. Symfony Messenger), ale nie tylko. System ten pozwala na ich publikowanie, późniejszą subskrypcję i przetwarzanie dzięki konsumerom. Ilość konsumerów możemy zwiększać elastycznie w zależności od potrzeby, co ułatwia nam wydajne skalowanie aplikacji. Dzięki temu jest ona w stanie obsłużyć ruch sieciowy, na który nie byliśmy wcześniej przygotowani.
Wiele mocnych stron RabbitMQ, w tym jego elastyczność, pochodzi ze specyfikacji AMQP. W przeciwieństwie do protokołów, takich jak HTTP i SMTP, specyfikacja AMQP definiuje nie tylko protokół sieciowy, ale także usługi oraz zachowania po stronie serwera.
Dodam, że rozszerzenie skrótu AMQP to Advanced Message Queuing Protocol, a pod linkiem https://www.amqp.org/about/what znajdziecie więcej przydatnych informacji na ten temat.
RabbitMQ ma pięć podstawowych składników, które należy zrozumieć, aby w świadomy sposób posługiwać się tym narzędziem. Niżej opisane zostaną one w skrócie, a jeżeli jesteście zainteresowani szczegółami, możecie znaleźć je w dokumentacji: https://www.rabbitmq.com/tutorials/amqp-concepts.html.
Publisher – tworzy i wysyła wiadomości do exchange. Zazwyczaj będzie to fragment naszej aplikacji.
Exchange – podejmuje decyzję, w których queues umieścić wiadomość.
Routes lub Binding – różne reguły, które łączą exchange z queue.
Queue – przechowuje wiadomości.
Consumer – może być to oddzielna aplikacja lub fragment naszej aplikacji, która pobiera wiadomości z queue i następnie je przetwarza.
Chcąc bardziej zobrazować temat queue, można go przyrównać do sklepu, w którym chcesz zrobić zakupy, exchange będzie magazynem a binding to trasa prowadząca z magazynu do sklepu. Co ważne, zawsze istnieje wiele dróg łączących opisane miejsca.
Wybierając narzędzie do obsługi kolejek trzeba zastanowić się nad biblioteką kliencką, która pozwoli na komunikację z RabbitMQ. W naszym przypadku wybór padł na Symfony Messenger. Pisanie message i message handlerów z użyciem tego narzędzia jest bardzo intuicyjne. Oprócz tego konfiguracja exchange i queue odbywa się w jednym miejscu. Warto podkreślić, że Symfony Messenger jest agnostyczny co oznacza, że system kolejkowania można oprzeć o RabbitMQ, Kafkę, Redis, relacyjną bazę danych, jak i inne narzędzia. Teraz określmy dokładnie, czym jest Symfony Messenger.
Kilka słów o Symfony Messenger
Messenger jest komponentem frameworku Symfony. Zapewnia możliwość wysyłania wiadomości, a następnie ich natychmiastowej obsługi w aplikacji (przetwarzanie synchroniczne) lub wysyłania ich przez transporty do późniejszej obsługi (przetwarzanie asynchroniczne). Symfony Messenger pozwala w prosty sposób zaimplementować CQRS pattern (https://martinfowler.com/bliki/CQRS.html) w naszej aplikacji.
Instrukcję instalacji Symfony Messenger i dodatku Symfony Messenger do AMQP można znaleźć w dokumentacji: https://symfony.com/doc/current/messenger.html. Warto zwrócić uwagę na to, że w sytuacji, w której wyspecyfikujemy, że Symfony Messenger ma stosować RabbitMQ, komponent ten korzysta „pod spodem” z następującej biblioteki https://github.com/pdezwart/php-amqp.
Zabierzmy się teraz za implementację. Postaramy się jasno przedstawić, jakie możliwości konfiguracji zachowań RabbitMQ daje nam Symfony Messenger oraz w jaki sposób wysyłać i odbierać z jego pomocą wiadomości.
Konfiguracja kolejek, exchange i bindingów w Symfony Messenger
Konfiguracja exchange, kolejek i bindingów w RabbitMQ z użyciem Symfony Messenger jest intuicyjna, wystarczy zmodyfikować plik messenger.yaml. Poniżej można znaleźć przykładową konfigurację wraz z opisem.
Podczas konfiguracji korzystamy z tego, że Symfony Messenger jest agnostyczny. Failure transport (failure_async_priority_high) został skonfigurowany tak, aby czerpał z relacyjnej bazy danych, nie RabbitMQ. Skorzystanie z takiego transportu pod błędnie przetworzone wiadomości zapewnia nam szereg korzyści, m.in:
łatwiejsze przeniesienie wiadomości z środowiska produkcyjnego na lokalne,
łatwiejsze podpięcie raportów,
Przykładowa implementacja producenta w Symfony Messenger
Tak, jak zostało to opisane wcześniej, producentem może być aplikacja lub fragment naszej aplikacji. W poniższym przykładzie producentem jest Kontroler, który przyjmuje żądania od klientów.
Tworzymy message, nie będzie on zawierał logiki biznesowej, jest on jedynie nośnikiem danych.
namespace App\Messenger;
use JetBrains\PhpStorm\Immutable;
#[Immutable]
class ExampleCommand
{
public function __construct(public readonly int $id)
{
}
}
Aby skorzystać z Symfony Messenger, „wstrzykujemy” zależność do MessageBusInterface. Wywołujemy na tym obiekcie metodę dispatch.
class ExampleController extends AbstractController
{
public function __construct(
private readonly MessageBusInterface $messageBus,
private readonly SerializerInterface $serializer,
){
}
#[Route('/index', name: 'app_index', methods: ['POST'])]
public function index(Request $request): Response
{
$message = $this->serializer->deserialize($request->getContent(), ExampleCommand::class, 'json');
$this->messageBus->dispatch(
$message,
[
new AmqpStamp(null, AMQP_MANDATORY, ['delivery_mode' => 2])
]
);
return $this->json([
'message' => 'Index created successfully',
]);
}
}
Pierwszym parametrem wywołania dispatch jest message, który ma zostać obsłużony. Kolejnym parametrem są różnego rodzaju stamp’y . W tym przypadku jest to AmqpStamp, który będzie sterował zachowaniem RabbitMQ w stosunku do wysłanej wiadomości
Przykładowa implementacja konsumera w Symfony
Konsumer deserializuje command i wykonuje odpowiednią logikę, wykorzystując dane zawarte w command’zie. Logika znajduje się w specjalnych klasach zwanych handler’ami, które implementują interfejs MessageHandlerInterface.
namespace App\Messenger;
use Symfony\Component\Messenger\Handler\Acknowledger;
use Symfony\Component\Messenger\Handler\MessageHandlerInterface;
class ExampleCommandHandler implements MessageHandlerInterface
{
public function __invoke(ExampleCommand $message)
{
return $message->id;
}
}
Dzięki autokonfiguracji Symfony , żeby dany message handler mógł być powiązany z określonym message’m, typ argumentu w __invoke musi wskazywać właśnie na klasę message’a. To wystarczy, by po dispatch ExampleCommand był obsłużony przez ExampleCommandHandler. Aby zobaczyć pełną listę powiązanych ze sobą messages i message handlerów należy wpisać w konsoli:
php bin/console debug:messenger
Gdy chcesz uruchomić konsumera, wpisz w command line:
Podczas publikowania wiadomości, do RabbitMQ klient wysyła tak naprawdę trzy tzw. frame’y. Można je przyrównać do wagonów w pociągu, każdy ma podobną zewnętrzną strukturę, ale przewożą inny ładunek.
Spośród 3 typów wiadomości to dzięki content header, a będąc bardziej konkretnym, dzięki strukturze danych nazwanej Basic.Properties, możemy kontrolować zachowanie RabbitMQ w stosunku do przesyłanej wiadomości. Content header zawiera metadane o wysyłanej do RabbitMQ wiadomości, czyli metadane o body. Wykorzystywany jest przez producentów do sterowania zachowaniem RabbitMQ .
Konfigurowanie wysyłania wiadomości do RabbitMQ – Symfony Messenger
Na początek wymieńmy przykładowe basic.properties, które modyfikują zachowanie RabbitMQ w stosunku do wysłanej przed publishera wiadomości. Znajdziecie je w poniższej tabeli.
W dokumentacji Symfony nie jest w jasny sposób przedstawione, jak dodać basic.properties do wiadomości z poziomu Symfony Messenger. Aby to zrobić, dodajemy do wysyłanej wiadomości odpowiedni AmqpStamp. Implementacja wygląda w następujący sposób:
Podsumowanie
Z tego tekstu dowiesz się:
czym są systemy kolejkowe i kiedy może zajść potrzeba ich wykorzystania,
jakie są podstawowe składniki RabbitMQ i Symfony Messenger,
jak wysyłać i dobierać wiadomości z użyciem Symfony Messenger,
jak tworzyć podstawową konfigurację w pliku messenger.yaml,
czym są Basic Properties i jak wysyłać je do RabbitMQ w wiadomościach z użyciem Symfony Messenger.
Połączenie RabbitMQ z Symfony Messenger jest szerokim tematem, a dokumentacja Symfony Messenger często nastręcza problemów. Opisywane narzędzia jednak z powodzeniem podnoszą wydajność aplikacji i rozładowują przejściowe wzrosty ruchu. Żeby móc z nich sprawnie i skutecznie korzystać, warto oprócz samej konfiguracji poznać wszystkie ograniczenia oraz sposoby na ich obchodzenie.
Jest to pierwszy z artykułów, w którym opisujemy funkcjonowanie RabbitMQ, a będzie ich więcej! Zapraszamy do lektury i śledzenia aktualności na naszym blogu.
PyCon PL to ogólnopolska konferencja integrująca środowisko programistów Pythona, a także środowiska biznesowe, wykorzystujące ten język w projektach komercyjnych. W listopadzie doczekała się czternastej edycji.
Oczywiście ciekawi branżowej wiedzy oraz nowinek technologicznych wzięliśmy udział w tym wydarzeniu! Co więcej, mieliśmy okazję podzielić się także własnymi doświadczeniami -Kazimierz Najmajer, nasz Senior Data Scientist poprowadził prelekcję Variational Autoencoders.
PyCon co roku skupia polskich i międzynarodowych ekspertów, zapraszając na interesujące prelekcje, a także warsztaty. Tym razem konferencja po przerwie wróciła w formie stacjonarnej, goszcząc kilkaset osób.
Infoshare to wydarzenie, które już na stałe wpisaliśmy do naszych kalendarzy. W tym roku wzięliśmy w tym evencie udział po raz kolejny, a drugi raz pod szyldem Silky Coders.
Uczestnictwo w tej największej w Europie Środkowo-Wschodniej konferencji technologicznej zawsze jest niesamowitym przeżyciem i świetną okazją do spotkań i rozmów, a także… podzielenia się wiedzą. Tak było i w tym roku – nasza Product Ownerka Anna Brodecka w ramach swojej prelekcji opowiedziała uczestnikom Infoshare m.in. o tym, co łączy algorytmy ML, RFID i branżę mody – czyli o money mappingu. Jeśli jesteście ciekawi tematu, zapraszamy do obejrzenia całego wystąpienia, które znajdziecie tutaj >>>.
Dla osób, które odwiedziły nasze stoisko, przygotowaliśmy oczywiście także coś specjalnego – możliwość wykonania customu naszych gadżetów.
Teraz pozostaje już tylko odliczać do kolejnej edycji – mamy nadzieję, że do zobaczenia!
Według danych Accenture liczba cyberataków wzrosła od 2014 r. o 67%. IBM wyliczył z kolei, że średni koszt naruszenia danych w 2021 r. wyniósł 4,24 mln dolarów. Mając to na uwadze specjaliści uważają, że pytanie nie brzmi już „czy”, a raczej „kiedy” firma lub organizacja zostanie zaatakowana bądź zmierzy się z poważnym incydentem bezpieczeństwa. Zwracają też uwagę, że w łagodzeniu jego skutków pomaga odpowiednia komunikacja. To m.in. o tym możecie przeczytać w najnowszym wydaniu „Security Magazine” w artykule, którego współautorem jest Mariusz Prociewicz z Silky Coders! -> https://www.politykabezpieczenstwa.pl/pl/a/07-2022-security-magazine
