2.8 MongoDB Sink Connector
Trường hợp tạo connector, Type là sink, Database là MongoDB
Pre-condition: Status CDC service healthy
Các bước tạo connector:
Bước 1: Tại thanh menu chọn Data Platform > chọn Workspace Management > chọn Workspace name
Bước 2: Tại phần My services chọn CDC service
Bước 3: Tại màn detail CDC service > Chọn tab Connectors > nhấn Create a connector
Bước 4: Nhập các thông tin màn Connector Information:
- Name (required): tên connector
Chú ý: Tên connector có thể chứa các kí tự chữ cái thường a-z hoặc các kí tự số 0-9. Không. Đặc biệt không dùng dấu cách có thể thay dấu cách bằng dấu “-”.
- Type**(required):** chọn sink
- Database (required): chọn MongoDB
Bước 5: Nhấn Next để chuyển qua màn Properties
Bước 6: Có hai lựa chọn: From FPT Database Engine, Manual configuration
- Trường hợp chọn Manual configuration - Điền các thông tin:
- Connection string (required): MongoDB connection uri
- Database (required): tên database
Chú ý: tên Database có thể là các chữ cái thường và các chữ cái hoa hoặc các chữ số từ 1-9. Đặc biệt không dùng dấu cách, có thể thay dấu cách bằng dấu ‘-’ và ‘_’
- Trường hợp chọn From FPT Database Engine - Điền các thông tin:
- Connection string (required): MongoDB connection uri
- Database (required): tên database
Chú ý: tên Database có thể là các chữ cái thường và các chữ cái hoa hoặc các chữ số từ 1-9. Đặc biệt không dùng dấu cách, có thể thay dấu cách bằng dấu ‘-’ và ‘_’
- Converter
- Converter key: chọn giá trị key cho converter
- Converter key schema enable: chọn giá trị có/không sử dụng schema trong Converter key
- Converter value: chọn giá trị value cho converter
- Converter value schema enable: chọn giá trị có/không sử dụng schema trong Converter value
- Topics (required): Danh sách các topics
Bước 7: Nhấn Next ở góc phải màn hình để chuyển qua màn Additional Properties
Bước 8: Điền các thông tin:
- Tasks max (required): Số lượng task mà connector có thể chạy đồng thời, nếu topics của có số lượng partition lớn hơn 1. Trong trường hợp task max > 1, message có thể consume không theo thứ tự (bạn cần đảm bảo key của message hoạt động đúng, khi đó các message cùng key sẽ đẩy vào cùng một partition).
- Database source: chọn loại Database source
- Map table: Hiển thị danh sách mapping giữa Topic và Index.
- Topic: Tên topic nhận dữ liệu thay đổi từ Source Connector.
- Create new: Bật để tạo mới index trên hệ thống đích; tắt để sử dụng index hiện có.
- Index: Tên index lưu dữ liệu đồng bộ từ topic tương ứng.
Bước 9. Nhấn Next để chuyển qua màn Review
Bước 10: Kiểm tra thông tin và nhấn nút Create để hoàn thành việc tạo connector.