Halaman ini diterjemahkan oleh Cloud Translation API.

Mengonfigurasi database SQL Server Amazon RDS

Langkah-langkah berikut membahas cara mengonfigurasi database SQL Server Amazon RDS untuk digunakan dengan Datastream:

Aktifkan pengambilan data perubahan (CDC) untuk database sumber Anda. Untuk mengaktifkan CDC untuk database sumber Anda, hubungkan ke database dan jalankan perintah berikut di perintah SQL, di terminal, atau menggunakan dasbor Amazon RDS:
```
EXEC msdb.dbo.rds_cdc_enable_db 'DATABASE_NAME'
```
Ganti DATABASE_NAME dengan nama database sumber Anda.
Aktifkan CDC di setiap tabel yang perubahannya perlu Anda rekam:
```
USE [DATABASE_NAME]
EXEC sys.sp_cdc_enable_table
@source_schema = N'SCHEMA_NAME',
@source_name = N'TABLE_NAME',
@role_name = NULL
GO
```
Ganti kode berikut:
- DATABASE_NAME: nama database sumber Anda
- SCHEMA_NAME: nama skema tempat tabel berada
- TABLE_NAME: nama tabel yang ingin Anda aktifkan CDC-nya
Mulai Agen SQL Server dan pastikan agen tersebut selalu berjalan. Jika SQL Server Agent tetap nonaktif selama jangka waktu yang lama, log mungkin terpotong, sehingga menyebabkan hilangnya data perubahan secara permanen yang tidak dibaca oleh Datastream.

Untuk informasi tentang cara menjalankan Agen SQL Server, lihat Memulai, menghentikan, atau memulai ulang instance Agen SQL Server.

Catatan: Sebaiknya aktifkan mulai ulang otomatis untuk layanan SQL Server Agent agar agen tidak nonaktif dalam waktu yang lebih lama.
Aktifkan isolasi snapshot.

Saat Anda mengisi ulang data dari database SQL Server, penting untuk memastikan snapshot yang konsisten. Jika Anda tidak menerapkan setelan yang dijelaskan di bagian ini, perubahan yang dilakukan pada database selama proses pengisian ulang dapat menyebabkan duplikat atau hasil yang salah, terutama untuk tabel tanpa kunci utama.

Mengaktifkan isolasi snapshot akan membuat tampilan sementara database Anda di awal proses pengisian ulang. Tindakan ini memastikan bahwa data yang disalin tetap konsisten, meskipun pengguna lain melakukan perubahan pada tabel aktif secara bersamaan. Mengaktifkan isolasi snapshot mungkin memiliki sedikit dampak pada performa, tetapi hal ini penting untuk ekstraksi data yang andal.

Untuk mengaktifkan isolasi snapshot:
1. Hubungkan ke database Anda menggunakan klien SQL Server.
2. Jalankan perintah berikut:
```
ALTER DATABASE DATABASE_NAME SET ALLOW_SNAPSHOT_ISOLATION ON;
```
Ganti DATABASE_NAME dengan nama database Anda.

Buat pengguna Datastream:

Hubungkan ke database sumber dan masukkan perintah berikut:
```
USE DATABASE_NAME;
```
Buat login yang akan digunakan saat menyiapkan profil koneksi di Datastream.
```
CREATE LOGIN YOUR_LOGIN WITH PASSWORD = 'PASSWORD';
```

Buat pengguna dan tetapkan peran db_owner dan db_denydatawriter kepada pengguna tersebut:

CREATE USER USER_NAME FOR LOGIN YOUR_LOGIN;

EXEC sp_addrolemember 'db_owner', 'USER_NAME';
EXEC sp_addrolemember 'db_denydatawriter', 'USER_NAME';

Tambahkan pengguna ini ke database master:

USE master;
CREATE USER USER_NAME FOR LOGIN YOUR_LOGIN;

Langkah tambahan yang diperlukan untuk metode CDC log transaksi

Langkah-langkah yang dijelaskan di bagian ini hanya diperlukan saat Anda mengonfigurasi database SQL Server sumber untuk digunakan dengan metode CDC log transaksi.

Berikan izin SELECT untuk fungsi sys.fn_dblog.

USE master;
GRANT SELECT ON sys.fn_dblog TO USER_NAME;

Tambahkan pengguna Anda ke database msdb dan tetapkan izin berikut kepada mereka:

USE msdb;
CREATE USER USER_NAME FOR LOGIN YOUR_LOGIN;
GRANT SELECT ON dbo.sysjobs TO USER_NAME;

Tetapkan izin berikut kepada pengguna Anda di database master:

  USE master;
  GRANT VIEW SERVER STATE TO YOUR_LOGIN;

Tetapkan periode retensi yang Anda inginkan agar perubahan tersedia di sumber.
```
USE [DATABASE_NAME]
EXEC sys.sp_cdc_change_job @job_type = 'capture' , @pollinginterval = 86399
EXEC sp_cdc_stop_job 'capture'
EXEC sp_cdc_start_job 'capture'
```
Parameter @pollinginterval diukur dalam hitungan detik dengan nilai yang direkomendasikan ditetapkan ke 86399. Ini berarti log transaksi mempertahankan perubahan selama 86.399 detik (satu hari). Menjalankan prosedur sp_cdc_start_job 'capture akan memulai setelan.

Siapkan pengamanan pemotongan log.

Untuk memastikan bahwa pembaca CDC memiliki cukup waktu untuk membaca log sekaligus mengizinkan pemotongan log untuk mencegah penggunaan ruang penyimpanan, Anda dapat menyiapkan pengamanan pemotongan log:

Hubungkan ke database menggunakan klien SQL Server.

Buat tabel dummy di database:

USE [DATABASE_NAME];
CREATE TABLE dbo.gcp_datastream_truncation_safeguard (
  [id] INT IDENTITY(1,1) PRIMARY KEY,
  CreatedDate DATETIME DEFAULT GETDATE(),
  [char_column] CHAR(8)
  );

Buat prosedur tersimpan yang menjalankan transaksi aktif selama periode yang Anda tentukan untuk mencegah pemotongan log:

CREATE PROCEDURE [dbo].[DatastreamLogTruncationSafeguard] @transaction_logs_retention_time INT
AS
BEGIN
  -- Start a new transaction
  BEGIN TRANSACTION;
  INSERT INTO dbo.gcp_datastream_truncation_safeguard (char_column) VALUES ('a')

DECLARE @formatted_time VARCHAR(5)
SET @formatted_time = CONVERT(VARCHAR(5), DATEADD(MINUTE, @transaction_logs_retention_time, 0), 108);
  -- Wait for X minutes before ending the transaction
  WAITFOR DELAY @formatted_time;
  -- Commit the transaction
  COMMIT TRANSACTION;
END;

Buat prosedur tersimpan lainnya. Kali ini, Anda akan membuat tugas yang menjalankan prosedur tersimpan yang Anda buat di langkah sebelumnya sesuai dengan jeda yang ditentukan:

CREATE PROCEDURE [dbo].[SetUpDatastreamJob] @transaction_logs_retention_time INT
AS
BEGIN
  DECLARE @database_name VARCHAR(MAX)
  SET @database_name =  (SELECT DB_NAME());;

  DECLARE @command_str VARCHAR(MAX);
  SET @command_str = CONCAT('Use ', @database_name,'; exec dbo.DatastreamLogTruncationSafeguard @transaction_logs_retention_time = ' + CAST(@transaction_logs_retention_time AS VARCHAR(10)));

  DECLARE @job_name VARCHAR(MAX);
SET @job_name =
  CONCAT(@database_name, '_', 'DatastreamLogTruncationSafeguardJob1')

    -- Add 3 schedules to the job to run again after specified time.
    IF
      NOT EXISTS(
        SELECT *
        FROM msdb.dbo.sysjobs
        WHERE name = @job_name
      )
        BEGIN
          EXEC
            msdb.dbo.sp_add_job
              @job_name
  = @job_name,
  @enabled = 1,
  @description = N'Execute the procedure to run an active transaction for x minutes.';

EXEC msdb.dbo.sp_add_jobstep @job_name = @job_name,
@step_name = N'Execute_DatastreamLogTruncationSafeguard',
@subsystem = N'TSQL',
@command = @command_str;

  -- Add a schedule that runs the stored procedure every given minutes starting now.
  DECLARE @schedule_name_1 VARCHAR(MAX);
  SET @schedule_name_1 = CONCAT(@database_name, '_', 'DatastreamEveryGivenMinutesFromNow')

  DECLARE @start_time_1 time;
  SET @start_time_1 = DATEADD(SECOND, 1, GETDATE());
  DECLARE @formatted_start_time_1 INT;
  SET @formatted_start_time_1 = CONVERT(INT, REPLACE(CONVERT(VARCHAR(8), @start_time_1, 114), ':' ,''));

  EXEC msdb.dbo.sp_add_schedule
  @schedule_name = @schedule_name_1,
  @freq_type = 4,  -- daily start
  @freq_subday_type = 4,  -- every X minutes daily
  @freq_interval = 1,
  @freq_subday_interval = @transaction_logs_retention_time,
  @active_start_time = @formatted_start_time_1;

  EXEC msdb.dbo.sp_attach_schedule
  @job_name = @job_name,
  @schedule_name = @schedule_name_1 ;

  -- Add a schedule that runs the stored procedure after every given minutes starting after some delay.
  DECLARE @schedule_name_2 VARCHAR(MAX);
  Set @schedule_name_2 = CONCAT(@database_name, '_', 'DatastreamEveryGivenMinutesAfterDelay');

  DECLARE @start_time_2 time;
  SET @start_time_2 = DATEADD(MINUTE, @transaction_logs_retention_time / 2, GETDATE());

  DECLARE @formatted_start_time_2 INT;
  SET @formatted_start_time_2 = CONVERT(INT, REPLACE(CONVERT(VARCHAR(8), @start_time_2, 114), ':' ,''));

  EXEC msdb.dbo.sp_add_schedule
  @schedule_name = @schedule_name_2,
  @freq_type = 4,  -- daily start
  @freq_subday_type = 4,  -- every x minutes daily
  @freq_interval = 1,
  @freq_subday_interval = @transaction_logs_retention_time,
  @active_start_time = @formatted_start_time_2;

  EXEC msdb.dbo.sp_attach_schedule
  @job_name = @job_name,
  @schedule_name = @schedule_name_2 ;

  -- Add a schedule that runs the stored procedure on the SQL Server Agent startup.
  DECLARE @schedule_name_agent_startup VARCHAR(MAX);
  Set @schedule_name_agent_startup = CONCAT(@database_name, '_', 'DatastreamSqlServerAgentStartupSchedule')

  EXEC msdb.dbo.sp_add_schedule
  @schedule_name = @schedule_name_agent_startup,
  @freq_type = 64,  -- start on SQL Server Agent startup
  @active_start_time = @formatted_start_time_1;

  EXEC msdb.dbo.sp_attach_schedule
  @job_name = @job_name,
  @schedule_name = @schedule_name_agent_startup ;

  EXEC msdb.dbo.sp_add_jobserver
  @job_name = @job_name,
  @server_name = @@servername ;
  END
END;

Jalankan prosedur tersimpan yang membuat tugas Datastream.
```
DECLARE @transaction_logs_retention_time INT = (INT)
EXEC [dbo].[SetUpDatastreamJob] @transaction_logs_retention_time
```
Ganti INT dengan jumlah menit yang ingin Anda simpan lognya. Contoh:
- Nilai 60 menetapkan waktu retensi ke 1 jam
- Nilai 24 * 60 menetapkan waktu retensi ke 1 hari
- Nilai 3 * 24 * 60 menetapkan waktu retensi ke 3 hari

Langkah selanjutnya

Pelajari lebih lanjut cara kerja Datastream dengan sumber SQL Server.