effect-patterns-streams-sinks

Umiejętność zawierająca 6 sprawdzonych wzorców Effect-TS dedykowanych pracy ze strumieniami danych (streams sinks). Nauczysz się, jak batching rekordy przed operacjami bazodanowymi, aby zwiększyć przepustowość i zmniejszyć obciążenie transakcji. Skill obejmuje praktyczne rozwiązania dla aplikacji Effect-TS, od paginacji API po efektywne wstawianie danych. Idealna dla developerów pracujących z asynchronicznym przetwarzaniem danych w TypeScript.

1. Zainstaluj skill w swoim projekcie Effect-TS, dodając go do konfiguracji Claude plugin lub agenta, który obsługuje umiejętności Effect-TS. 2. Zidentyfikuj scenariusz, w którym przetwarzasz dane ze źródła (np. API, baza danych) i musisz je wysłać do innego miejsca docelowego (sink). Typowe przypadki to batching rekordów przed wstawieniem do bazy lub transformacja strumienia danych. 3. Przejrzyj dostępne wzorce w skill, szczególnie wzorzec Batch Insert Stream Records into Database, który pokazuje, jak pagynować dane z API i grupować je w partie przed operacją bazodanową. 4. Zastosuj wzorzec do swojego kodu, dostosowując interfejsy danych (User, PaginatedResponse) do struktury Twoich rekordów. Upewnij się, że Stream.paginateEffect pobiera dane z Twojego źródła, a Sink.forEach lub podobna operacja wysyła partie do celu. 5. Przetestuj przepływ danych, monitorując rozmiary partii i opóźnienia, aby upewnić się, że batching rzeczywiście poprawia wydajność. Dostosuj rozmiar partii (chunk size) na podstawie charakterystyki Twojej bazy danych i przepustowości sieci. 6. Wykorzystaj pozostałe wzorce dla bardziej zaawansowanych scenariuszy, takich jak obsługa błędów w strumieniach, transformacje warunkowe lub agregacja danych przed zapisem.