0 / 0
Go back to the English version of the documentation
Kurs integracji danych: replikowanie danych
Last updated: 09 lis 2023
Kurs integracji danych: replikowanie danych

Ten kurs służy do konfigurowania replikacji danych między źródłową i docelową składnicą danych za pomocą przypadku użycia integracji danych w wersji próbnej produktu Data Fabric. Celem jest użycie opcji Data Replication w celu zintegrowania informacji o wyniku kredytowym ze źródła danych dostawcy Db2 on Cloud przez skonfigurowanie w czasie zbliżonym do rzeczywistego kanału informacyjnego replikacji ciągłej z efektywnym przechwytywaniem danych ze źródłowej bazy danych do instancji usługi Event Streams banku Golden Bank. Event Streams to magistrala komunikatów o wysokiej przepustowości zbudowana przy użyciu platformy Apache Kafka. Jest zoptymalizowany pod kątem przyjmowania zdarzeń do platformy IBM Cloud i dystrybucji strumienia zdarzeń między usługami i aplikacjami. Więcej informacji na temat funkcji Event Streamszawiera sekcja Dodatkowe informacje .

Szybki start: Jeśli nie utworzono jeszcze przykładowego projektu dla tego kursu, należy uzyskać dostęp do przykładowego projektu integracji danych w galerii.

Historia kursu jest taka, że Golden Bank musi stosować się do nowego rozporządzenia, w którym nie może pożyczać osobom ubiegającym się o pożyczkę z niepełnym kwalifikacją. Jako inżynier danych w Golden Bank, musisz zapewnić dostęp do najbardziej aktualnych wyników kredytowych osób ubiegających się o pożyczkę. Te oceny kredytowe pochodzą z bazy danych Db2 on Cloud , której właścicielem jest zewnętrzny dostawca i są stale dostarczane do koncentratora Event Streams Golden Bank. Dane w koncentratorze Event Streams są używane przez aplikację do wyszukiwania wyników kredytowych dla wnioskodawców ubiegających się o kredyt hipoteczny w celu określenia zatwierdzenia kredytu dla zakwalifikowanych kandydatów.

Poniższy animowany obraz udostępnia szybki podgląd tego, co zostanie wykonane po zakończeniu kursu. Kliknij obraz, aby wyświetlić większy obraz.

Animowany obraz

Podgląd kursu

W tym kursie zostaną wykonane następujące czynności:

Obejrzyj wideo Obejrzyj ten film wideo, aby wyświetlić podgląd kroków tego kursu. W interfejsie użytkownika wyświetlanym na filmie wideo mogą występować niewielkie różnice. Film wideo ma być towarzyszem napisanego kursu.

Ten film wideo zawiera wizualną metodę zapoznawania się z pojęciami i zadaniami opisanymi w tej dokumentacji.



  • Użyj obrazu wideo

    Wskazówka: Rozpocznij film wideo, a następnie podczas przewijania kursu film wideo przechodzi do trybu obrazowania. Zamknij spis treści wideo, aby uzyskać najlepsze doświadczenia z obrazem. Istnieje możliwość użycia trybu obrazowania w obrazie, dzięki czemu można śledzić film wideo podczas wykonywania zadań w tym kursie. Kliknij znaczniki czasu dla każdego zadania, które ma być wykonywane.

    Poniższy animowany obraz przedstawia sposób korzystania z funkcji obrazków wideo i spisu treści:

    Jak korzystać z obrazka w obrazie i rozdziałów

    Uzyskaj pomoc w społeczności

    Aby uzyskać pomoc dotyczącą tego kursu, można zadać pytanie lub znaleźć odpowiedź na forum dyskusyjnym społeczności Cloud Pak for Data.

    Konfigurowanie okien przeglądarki

    Aby uzyskać optymalne dopasowanie do tego kursu, otwórz stronę Cloud Pak for Data w jednym oknie przeglądarki i pozostaw ten kurs otwarty w innym oknie przeglądarki, aby łatwo przełączać się między dwiema aplikacjami. Rozważ rozmieszczenie dwóch okien przeglądarki obok siebie, aby ułatwić sobie śledzenie.

    Kurs i interfejs użytkownika obok siebie

    Wskazówka: Jeśli podczas wykonywania tego kursu w interfejsie użytkownika pojawi się prezentacja z przewodnikiem, kliknij opcję Być może później.

    Początek strony

  • Zarejestruj się, aby korzystać z Cloud Pak for Data as a Service

    Należy zarejestrować się w usłudze Cloud Pak for Data as a Service i udostępnić niezbędne usługi na potrzeby integracji danych.


    Ikona filmów wideo Obejrzyj następujący film wideo, aby dowiedzieć się więcej o strukturze danych w produkcie Cloud Pak for Data.

    Ten film wideo zawiera wizualną metodę zapoznawania się z pojęciami i zadaniami opisanymi w tej dokumentacji.

    Sprawdź wymagane udostępnione usługi

    Film wideo z kursu podglądu Aby wyświetlić podgląd tej czynności, należy obejrzeć film wideo rozpoczynający się od strony 01:29.

    Ważne: Opcja Data Replication jest dostępna tylko w regionie Dallas. Jeśli to konieczne, przed kontynuacją przełącz się na region Dallas.

    Aby sprawdzić lub udostępnić niezbędne usługi, wykonaj następujące kroki:

    1. W programie Cloud Pak for Datasprawdź, czy jesteś w regionie Dallas. Jeśli nie, kliknij menu rozwijane regionu, a następnie wybierz opcję Dallas.
      Zmień region

    2. Z Cloud Pak for Data menu nawigacyjnego Menu nawigacjiwybierz opcję Usługi > Instancje usług.

    3. Użyj listy rozwijanej Produkt , aby określić, czy istnieje istniejąca instancja usługi Data Replication .

    4. Aby utworzyć instancję usługi Data Replication , kliknij opcję Dodaj usługę.

      1. Wybierz opcję Data Replication.

      2. Wybierz plan Lite .

      3. Kliknij makro Create.

    5. Poczekaj, aż usługa Data Replication zostanie udostępniona, co może potrwać kilka minut.

    6. Powtórz te kroki, aby sprawdzić lub udostępnić następujące dodatkowe usługi:

      • Watson Studio
      • Cloud Object Storage
      • Event Streams -może zostać wyświetlona prośba o zalogowanie się do konta w programie IBM Cloud .

    Ikona punktu kontrolnego Sprawdź postęp

    Na poniższym obrazku przedstawiono udostępnione instancje usługi. Teraz można przystąpić do tworzenia przykładowego projektu.

    Udostępnione usługi

    Utwórz przykładowy projekt

    Film wideo z kursu podglądu Aby wyświetlić podgląd tego zadania, należy obejrzeć film wideo rozpoczynający się od strony 02:19.

    Jeśli dla tego kursu jest już dostępny przykładowy projekt, przejdź do sekcji Czynność 1. W przeciwnym razie wykonaj następujące kroki:

    1. Uzyskaj dostęp do przykładowego projektu kursu integracji danych w galerii.

    2. Kliknij opcję Utwórz projekt.

    3. Jeśli zostanie wyświetlona prośba o powiązanie projektu z instancją Cloud Object Storage , wybierz z listy instancję Cloud Object Storage .

    4. Kliknij makro Create.

    5. Poczekaj na zakończenie importowania projektu, a następnie kliknij opcję Wyświetl nowy projekt , aby sprawdzić, czy projekt i zasoby aplikacyjne zostały pomyślnie utworzone.

    6. Kliknij kartę Zasoby , aby wyświetlić połączenia, połączony zasób danych i notatnik.

    Uwaga: Może zostać wyświetlony przewodnik przedstawiający kursy dołączone do tego przypadku użycia. Odsyłacze w przewodniku otwierają te instrukcje kursu.

    Ikona punktu kontrolnego Sprawdź postęp

    Na poniższym obrazku przedstawiono kartę Zasoby w przykładowym projekcie. Teraz można rozpocząć kurs.

    Przykładowy projekt


    Początek strony


  • Film wideo z kursu podglądu Aby wyświetlić podgląd tego zadania, należy obejrzeć film wideo rozpoczynający się od strony 03:05.

    W ramach wymagań wstępnychudostępniono nową instancję Event Streams . Teraz należy skonfigurować tę instancję usługi. Wykonaj następujące kroki, aby:

    • Utwórz temat, w którym będą przechowywane dane replikowane z danych źródłowych w produkcie Db2 on Cloud. Temat stanowi podstawę przepływów Event Streams . Dane przechodzą przez temat od aplikacji generujących do aplikacji konsumujących.

    • Skopiuj przykładowy kod, który zawiera informacje o serwerze startowym niezbędne do skonfigurowania replikacji danych.

    • Utwórz referencje, które będą używane do tworzenia połączenia z usługą w projekcie.

    1. Wróć do konsoli IBM Cloud Lista zasobów.

    2. Rozwiń sekcję Integracja .

    3. Kliknij nazwę instancji usługi dla instancji Event Streams , aby wyświetlić szczegóły instancji.

    4. Najpierw, aby utworzyć temat, kliknij stronę Tematy .

      1. Kliknij opcję Utwórz temat.

      2. W polu Nazwa tematuwpisz golden-bank-mortgage.

      3. Kliknij przycisk Dalej.

      4. W sekcji Partitions (Partycje) zaakceptuj wartość domyślną, a następnie kliknij przycisk Next(Dalej).

      5. W sekcji Czas przechowywania komunikatów zaakceptuj wartość domyślną i kliknij opcję Utwórz temat.

      6. Otwórz edytor tekstu i wklej nazwę tematu golden-bank-mortgage do pliku tekstowego, aby użyć go później.

    5. Następnie na stronie Tematy kliknij opcję Połącz z tą usługą , aby pobrać informacje o połączeniu.

      1. Skopiuj wartość z pola Serwer startowy . Serwer startowy jest wymagany podczas tworzenia połączenia z instancją Event Streams w projekcie.

      2. Wklej wartość serwera startowego do tego samego pliku tekstowego w celu późniejszego użycia.

      3. Kliknij kartę Przykładowy kod .

      4. Skopiuj wartość z pola Przykładowe właściwości konfiguracyjne . Niektóre właściwości z tego fragmentu kodu zostaną użyte do nawiązania bezpiecznego połączenia z usługą.

      5. Wklej przykładowy kod do tego samego pliku tekstowego, aby użyć go później.

      6. Kliknij przycisk X , aby zamknąć panel Połącz z tą usługą .

    6. Na koniec, aby utworzyć referencje, kliknij stronę Referencje usługi .

      1. Kliknij opcję Nowe informacje autoryzacyjne.

      2. Zaakceptuj nazwę domyślną lub zmień ją, jeśli chcesz.

      3. W polu Rolazaakceptuj wartość domyślną Menedżer.

      4. Rozwiń sekcję Opcje zaawansowane .

      5. W polu Wybierz identyfikator usługi wybierz opcję Generuj automatycznie.

      6. Kliknij opcję Dodaj.

      7. Kliknij ikonę Kopiuj do schowka znajdującą się obok nowych informacji autoryzacyjnych.

      8. Wklej referencje do tego samego pliku tekstowego, aby użyć ich później.

    Plik tekstowy powinien zawierać wszystkie następujące informacje:

    TOPIC NAME: golden-bank-mortgage
    
    BOOTSTRAP SERVER FIELD
    broker-5-7w81scvsqh485hbz.kafka.svc04.us-south.eventstreams.cloud.ibm.com:9093,broker-1-7w81scvsqh485hbz.kafka.svc04.us-south.eventstreams.cloud.ibm.com:9093,broker-2-7w81scvsqh485hbz.kafka.svc04.us-south.eventstreams.cloud.ibm.com:9093,broker-0-7w81scvsqh485hbz.kafka.svc04.us-south.eventstreams.cloud.ibm.com:9093,broker-3-7w81scvsqh485hbz.kafka.svc04.us-south.eventstreams.cloud.ibm.com:9093,broker-4-7w81scvsqh485hbz.kafka.svc04.us-south.eventstreams.cloud.ibm.com:9093
    
    SAMPLE CODE
    bootstrap.servers=broker-5-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,broker-0-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,broker-2-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,broker-1-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,broker-3-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,broker-4-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093
    sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="token" password="<APIKEY>";
    security.protocol=SASL_SSL
    sasl.mechanism=PLAIN
    ssl.protocol=TLSv1.2
    ssl.enabled.protocols=TLSv1.2
    ssl.endpoint.identification.algorithm=HTTPS
    
    CREDENTIALS
    {
      "api_key": "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx",
      "apikey": "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx",
      "bootstrap_endpoints": "broker-2-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,broker-0-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,broker-4-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,broker-5-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,broker-3-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,broker-1-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093",
      "iam_apikey_description": "Auto-generated for key crn:v1:bluemix:public:messagehub:us-south:a/a53b11fc95fcca4d96484d0de5f3bc3c:6b5a2cb2-74ef-432d-817f-f053873e7ed2:resource-key:96372942-5d26-4c59-8ca4-41ab6766ba91",
      "iam_apikey_name": "Service credentials-1",
      "iam_role_crn": "crn:v1:bluemix:public:iam::::serviceRole:Manager",
      "iam_serviceid_crn": "crn:v1:bluemix:public:iam-identity::a/a53b11fc95fcca4d96484d0de5f3bc3c::serviceid:ServiceId-4773bed1-f423-43ea-adff-469389dca54c",
      "instance_id": "6b5a2cb2-74ef-432d-817f-f053873e7ed2",
      "kafka_admin_url": "https://pqny71x0b9vh7nwh.svc11.us-south.eventstreams.cloud.ibm.com",
      "kafka_brokers_sasl": [
        "broker-2-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093",
        "broker-0-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093",
        "broker-4-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093",
        "broker-5-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093",
        "broker-3-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093",
        "broker-1-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093"
      ],
      "kafka_http_url": "https://pqny71x0b9vh7nwh.svc11.us-south.eventstreams.cloud.ibm.com",
      "password": "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx",
      "user": "token"
    

    Ikona punktu kontrolnego Sprawdź postęp

    Na poniższym obrazku przedstawiono stronę Tematy dla instancji Event Streams w programie IBM Cloud. Teraz można utworzyć połączenie z instancją Event Streams w projekcie.

    Strona Tematy


    Początek strony


  • Film wideo z kursu podglądu Aby wyświetlić podgląd tego zadania, należy obejrzeć film wideo o godzinie 05:06.

    Przykładowy projekt obejmuje połączenie z instancją bazy danych Db2 on Cloud , w której przechowywane są dane źródłowe. Aby wyświetlić zasób połączenia i dane oceny zdolności kredytowej, wykonaj następujące kroki:

    1. Wróć do karty przeglądarki Cloud Pak for Data as a Service . Zostanie wyświetlony projekt integracji danych. Jeśli projekt nie jest widoczny, wykonaj następujące kroki:

      1. Z Cloud Pak for Data menu nawigacyjnego Menu nawigacjiwybierz opcję Projekty > Wyświetl wszystkie projekty.

      2. Kliknij projekt Integracja danych , aby go otworzyć.

    2. Na karcie Zasoby kliknij opcję Wszystkie zasoby.

    3. Znajdź zasób połączenia Data Fabric (wersja próbna)- Db2 on Cloud -źródło .

    4. Zlokalizuj połączony zasób danych CREDIT_SCORE .

    5. Kliknij zasób CREDIT_SCORE , aby wyświetlić podgląd. Ten zasób danych jest odwzorowywany na tabelę CREDIT_SCORE w schemacie BANKING w instancji Db2 on Cloud dostawcy. Zawiera on informacje o kandydatach do ubiegania się o kredyt hipoteczny, takie jak identyfikator, nazwisko, adres i wynik kredytowy. Chcesz skonfigurować replikację danych dla tego zasobu danych.

    6. Kliknij nazwę projektu Integracja danych w ścieżce nawigacyjnej, aby powrócić do projektu.
      Ścieżka nawigacji

    Ikona punktu kontrolnego Sprawdź postęp

    Na poniższym obrazku przedstawiono zasób danych oceny kredytowej w przykładowym projekcie. Teraz można utworzyć połączenie z usługą Event Streams w tym projekcie.

    Zasób danych oceny kredytowej


    Początek strony


  • Film wideo z kursu podglądu Aby wyświetlić podgląd tego zadania, należy obejrzeć film wideo o godzinie 05:33.

    Aby skonfigurować replikację, wymagane jest również połączenie z nową instancją Event Streams , która została udostępniona w ramach wymagań wstępnych przy użyciu informacji zebranych w zadaniu 1. Aby utworzyć zasób połączenia, wykonaj następujące kroki:

    1. Na karcie Zasoby kliknij opcję Nowy zasób > Połączenie.

    2. Dla konektora wybierz opcję Apache Kafkai kliknij przycisk Wybierz.

    3. W polu Nazwawpisz Event Streams.

    4. W sekcji Szczegóły połączeniawypełnij następujące pola:

      • Nazwa hosta serwera Kafka : Wklej wartość serwera startowego z pliku tekstowego utworzonego w sekcji Czynność 1.
      • Bezpieczne połączenie: wybierz opcję SASL_SSL.
      • Nazwa użytkownika: Wklej wartość user z referencji usługi w pliku tekstowym. Zwykle jest to wartość token.
      • Hasło: Wklej wartość password z referencji usługi w pliku tekstowym.
    5. Kliknij przycisk Testuj połączenie.

    6. Po pomyślnym wykonaniu testu kliknij przycisk Utwórz. Jeśli test nie powiedzie się, sprawdź informacje skopiowane i wklejone z pliku tekstowego, a następnie spróbuj ponownie. Jeśli zostanie wyświetlona prośba o potwierdzenie utworzenia połączenia bez ustawiania położenia i suwerenności, ponownie kliknij przycisk Utwórz .

    7. Kliknij opcję Wszystkie zasoby , aby wyświetlić nowe połączenie.

    Ikona punktu kontrolnego Sprawdź postęp

    Na poniższym obrazku przedstawiono kartę Zasoby w przykładowym projekcie przedstawiającą nowy zasób połączenia Event Streams . Teraz można powiązać usługę Data Replication z tym projektem.

    Zasób połączenia strumieni EVent


    Początek strony


  • Film wideo z kursu podglądu Aby wyświetlić podgląd tego zadania, należy obejrzeć film wideo o godzinie 06:31.

    Aby korzystać z usługi Data Replication w projekcie, należy powiązać z nim instancję usługi. Aby powiązać usługę Event Streams z projektem integracji danych, wykonaj następujące kroki:

    1. W projekcie Integracja danych kliknij kartę Zarządzaj .

    2. Kliknij stronę Usługi i integracje .

    3. Kliknij opcję Powiąż usługę.

    4. Zaznacz pole wyboru obok instancji usługi Data Replication .

    5. Kliknij opcję Powiąż.

    6. Kliknij przycisk Anuluj , aby powrócić do strony Usługi i integracje .

    Ikona punktu kontrolnego Sprawdź postęp

    Na poniższym obrazku przedstawiono stronę Usługi i integracje z wyświetloną usługą Data Replication . Teraz można skonfigurować replikację danych.

    Powiąż usługę z projektem


    Początek strony


  • Film wideo z kursu podglądu Aby wyświetlić podgląd tego zadania, należy obejrzeć film wideo o godzinie 06:52.

    Teraz można utworzyć zasób Data Replication , aby rozpocząć ciągłą replikację danych między źródłem Db2 on Cloud i celem Event Streams . Aby skonfigurować replikację danych, wykonaj następujące kroki:

    1. Kliknij kartę Zasoby w projekcie.

    2. Kliknij opcję Nowy zasób.

    3. Wybierz typ zasobu Data Replication .

    4. W polu Nazwawpisz CreditScoreReplication.

    5. Kliknij opcję Opcje źródła.

    6. Na stronie Opcje źródła wybierz opcję Data Fabric (wersja próbna)- Db2 on Cloud -Źródło z listy połączeń.

    7. Kliknij opcję Wybierz dane.

    8. Na stronie Wybierz dane wybierz schemat BANKING > tabelę CREDIT_SCORE .

    9. Kliknij opcję Opcje docelowe.

    10. Na stronie Opcje docelowe wybierz z listy połączeń pozycję Strumienie zdarzeń .

    11. W polu Temat domyślny wklej nazwę tematu utworzonego w czynności 1( golden-bank-mortgage).

    12. Zaakceptuj wartość domyślną w pozostałych polach i kliknij przycisk Przegląd.

    13. Przejrzyj podsumowanie i kliknij przycisk Utwórz.

    Ikona punktu kontrolnego Sprawdź postęp

    Na poniższym obrazku przedstawiono ekran ReplicateCreditScoreData z zatrzymaną replikacją. Teraz można uruchomić replikację danych.

    Zasób replikacji danych


    Początek strony


  • Film wideo z kursu podglądu Aby wyświetlić podgląd tego zadania, należy obejrzeć film wideo rozpoczynający się od strony 07:53.

    Po utworzeniu zasobu Data Replication można uruchomić replikację danych i wyświetlić informacje o statusie replikacji. Aby uruchomić replikację danych, wykonaj następujące czynności:

    1. Na ekranie CreditScoreReplication (Replikacja CreditScore) kliknij ikonę Run replication (Uruchom replikację) Uruchom replikację , aby rozpocząć proces replikacji.

    2. Jeśli jest to pierwsze uruchomienie zasobu Data Replication , zostanie wyświetlona prośba o podanie klucza API. Zasoby replikacji danych używają osobistego klucza API IBM Cloud do bezpiecznego wykonywania operacji replikacji bez zakłóceń.

      • Jeśli istnieje klucz API, kliknij opcję Użyj istniejącego klucza API, wklej klucz API i kliknij przycisk Uruchom.
      • Jeśli nie masz istniejącego klucza API, kliknij opcję Wygeneruj nowy klucz API, a następnie kliknij opcję Generuj i uruchom. Zapisz klucz API do użycia w przyszłości, a następnie kliknij przycisk Zamknij.
    3. W sekcji Dzienniki zdarzeń kliknij ikonę Odśwież Ikona odświeżania , aby wyświetlić nowe komunikaty.

    4. Po kilku minutach w sekcji Dzienniki zdarzeń zostanie wyświetlony komunikat Completed initial synchronization for table "BANKING"."CREDIT_SCORE" .

    Od tego momentu wszelkie zmiany w BANKING.CREDIT_SCORE w instancji Db2 on Cloud zostanie wykryta automatycznie i zreplikowana do celu.

    Ikona punktu kontrolnego Sprawdź postęp

    Na poniższym obrazku przedstawiono ekran replikacji CreditScorez uruchomioną replikacją i komunikatami w dzienniku zdarzeń. Teraz można monitorować replikację, obserwując status zasobu replikacji, zdarzenia i metryki oraz sprawdzając, czy dane są replikowane.

    Zasób replikacji danych jest uruchomiony


    Początek strony


  • Film wideo z kursu podglądu Aby wyświetlić podgląd tego zadania, należy obejrzeć film wideo o godzinie 09:08.

    Można użyć kodu Python , aby sprawdzić, czy dane oceny kredytowej zostały zreplikowane do koncentratora Event Streams Golden Bank. Przykładowy projekt zawiera notatnik Jupyter zawierający przykładowy kod Python . Aby edytować i uruchomić kod w notatniku, wykonaj następujące kroki:

    1. Kliknij nazwę projektu Integracja danych w ścieżce nawigacyjnej, aby powrócić do projektu.
      Ścieżka nawigacji

    2. Kliknij kartę Zasoby.

    3. Kliknij opcję Wszystkie zasoby.

    4. Kliknij menu Menu przepełnienia Przepełnienie na końcu wiersza notatnika Replikacja danych programu Monitor i wybierz opcję Edytuj.

    5. Uruchom pierwszą komórkę kodu, aby zainstalować bibliotekę Kafka-python.

    6. Zmodyfikuj drugą komórkę, używając informacji zapisanych w pliku tekstowym z Czynności 1.

      • topic: Wklej nazwę tematu. Ta wartość to golden-bank-mortgage.

      • bootstrap_servers: Wklej wartość serwera startowego z pliku tekstowego, która powinna wyglądać podobnie do następującej wartości:

        broker-5-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,
        broker-0-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,
        broker-2-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,
        broker-1-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,
        broker-3-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093,
        broker-4-pqny71x0b9vh7nwh.kafka.svc11.us-south.eventstreams.cloud.ibm.com:9093
        
      • sasl_plain_username: Wklej wartość user z referencji usługi w pliku tekstowym. Zwykle jest to wartość token.

      • security_protocol: Wklej wartość security.protocol z pliku tekstowego. Zwykle jest to wartość SASL_SSL.

      • sasl_mechanism: Wklej wartość sasl.mechanism z pliku tekstowego. Zwykle jest to wartość PLAIN.

      • sasl_plain_password: Wklej wartość password z referencji usługi w pliku tekstowym.

    7. Po wprowadzeniu wszystkich wartości uruchom kod w drugiej komórce, aby udostępnić informacje o połączeniu dla instancji Event Streams .

    8. Uruchom kod w trzeciej komórce, aby wykorzystać rekordy z tematu Event Streams (Strumienie zdarzeń).

    9. Uruchom kod w czwartej komórce, aby wydrukować komunikaty przechwycone do obiektu konsumenta.

    10. Przejrzyj dane wyjściowe zawierające treść komunikatów dostarczonych przez replikację w temacie Event Streams . Porównaj to z zasobem danych CREDIT_SCORE, który był wyświetlany w zadaniu 2.

    11. Kliknij opcję Plik > Zapisz , aby zapisać notatnik Jupyter z zapisanymi referencjami.

    Ikona punktu kontrolnego Sprawdź postęp

    Na poniższym obrazku przedstawiono notatnik Monitoruj replikację danych po pomyślnym uruchomieniu kodu.

    Notatnik Jupyter do monitorowania replikacji danych


    Początek strony

Jako inżynier danych w banku Golden Bank, konfigurując replikację danych między tabelą CREDIT_SCORE w źródłowej bazie danych Db2 on Cloud i tematem w sekcji Event Streams, można skonfigurować stały dostęp do najbardziej aktualnych wyników kredytowych wnioskodawców ubiegających się o pożyczkę. Jeśli wynik kredytowy wnioskodawcy ulegnie zmianie, osoby zatwierdzające kredyty hipoteczne banku Golden Bank będą miały dostęp do tych zmian w czasie zbliżonym do rzeczywistego.

Czyszczenie (opcjonalne)

Jeśli chcesz ponownie skorzystać z kursów w przypadku użycia integracji danych, usuń następujące artefakty.

Artefakt Usuwanie
Instancje usługi Data Replication i Event Streams 1. Z menu nawigacyjnego wybierz opcję Usługi > Instancje usług.
2. Kliknij menu Działanie obok nazwy usługi i wybierz opcję Usuń.
Przykładowy projekt integracji danych Usuwanie projektu

Następne kroki

Więcej inform.

Temat nadrzędny: Kursy dotyczące struktury danych

Generative AI search and answer
These answers are generated by a large language model in watsonx.ai based on content from the product documentation. Learn more