建立及設定管線

您可以建立一或多個載入或匯出管線。建立管線時，可以使用參數和設定管線屬性來設定管線。

建立和設定管線的選項如下：

載入管線：
- 請參閱建立及設定用於載入資料的管線。
匯出管線：
- 使用日期或時戳資料欄作為追蹤較新資料的索引鍵，將查詢的增量結果匯出至物件存放區。請參閱建立及設定匯出時戳資料欄的管線。
- 使用日期或時戳資料欄作為追蹤較新資料的索引鍵，將表格的增量資料匯出至物件存放區。請參閱建立及設定匯出時戳資料欄的管線。
- 使用查詢將表格的資料匯出至物件存放區，以選取資料而不參照日期或時戳資料欄 (讓管線匯出查詢為每個排程器執行選取的所有資料)。請參閱建立及設定管線以匯出查詢結果 (不含時戳) 。

建立和設定用於載入資料的管線

您可以建立管線，將資料從物件存放區或目錄中的外部檔案載入至 Autonomous Database 中的表格。

載入管線會使用放置在物件存放區或目錄中的資料，並將其載入 Autonomous Database 中的表格。建立載入管線時，當新的資料檔到達管線時，管線會定期執行，以使用放置在來源位置的資料。您也可以使用管線可靠地複製檔案 (具備恢復和重試功能)，從來源位置到資料庫上的表格。

使用載入管線時，管線套件會使用 DBMS_CLOUD.COPY_DATA 來載入資料。

在您的 Autonomous Database 上，使用現有表格或建立正在載入資料的資料庫表格。舉例而言：

CREATE TABLE EMPLOYEE
            (name     VARCHAR2(128),
             age      NUMBER,
             salary   NUMBER);

建立管線以從物件存放區或從目錄物件載入資料。

BEGIN
     DBMS_CLOUD_PIPELINE.CREATE_PIPELINE(
        pipeline_name => 'MY_PIPE1',
        pipeline_type => 'LOAD',
        description   => 'Load metrics from object store into a table'
  );
END;
/

如需詳細資訊，請參閱CREATE_PIPELINE 程序。

建立證明資料物件以存取包含您所載入檔案的物件存放區。

您可以指定屬性為 credential_name 之管線來源位置的證明資料。如果您未在下一個步驟中提供 credential_name，則 credential_name 值會設為 NULL。當 location 屬性為公用或預先認證的 URL 時，您可以使用預設的 NULL 值。

如需詳細資訊，請參閱CREATE_CREDENTIAL 程序。
設定管線屬性，包括必要屬性：location、table_name 和 format。
案例 1：建立從物件存放區載入資料的管線。
```
BEGIN
     DBMS_CLOUD_PIPELINE.SET_ATTRIBUTE(
       pipeline_name => 'MY_PIPE1',
       attributes    => JSON_OBJECT(
            'credential_name' VALUE 'OBJECT_STORE_CRED',
            'location' VALUE 'https://objectstorage.us-phoenix-1.oraclecloud.com/n/namespace-string/b/bucketname/o/',
            'table_name' VALUE 'employee',
            'format' VALUE '{"type":"json", "columnpath":["$.NAME", "$.AGE", "$.SALARY"]}',
            'priority' VALUE 'HIGH',
            'interval' VALUE '20')
  );
END;
/
```
案例 2：建立用於從目錄物件載入資料的管線。
```
BEGIN
     DBMS_CLOUD_PIPELINE.SET_ATTRIBUTE(
       pipeline_name => 'MY_PIPE1',
       pipeline_type => 'LOAD',
       attributes    => JSON_OBJECT(
            'location' VALUE 'MY_DIR:*.csv',
            'table_name' VALUE 'employee',
            'format' VALUE '{"type":"csv"}',
            'priority' VALUE 'HIGH',
            'interval' VALUE '20')
  );
END;
/
```
下列屬性必須設為在兩種情況下執行載入管線：
- location：指定物件存放區或目錄物件上的來源檔案位置。
- table_name：指定您正在載入資料的資料庫中的表格。您指定的 location 適用於每個管線一個 table_name。
- format：描述您正在載入之資料的格式。
  
  如需詳細資訊，請參閱 DBMS_CLOUD 套件格式選項。
credential_name 是您在上一個步驟中建立的證明資料。

priority 值決定平行載入的檔案數目。優先順序較高的管線會消耗更多資料庫資源，並比以較低優先順序執行更快完成每個執行。

interval 值指定管線工作連續執行之間的時間間隔 (分鐘)。預設 interval 為 15 分鐘。

如需有關管線屬性的詳細資訊，請參閱 DBMS_CLOUD_PIPELINE 屬性。
建立管線之後，您可以測試管線或啟動管線：
- 測試管線
- 啟動管道

或者，若要設定 JSON 的格式，您可以使用下列格式：

BEGIN
    DBMS_CLOUD_PIPELINE.SET_ATTRIBUTE(
        pipeline_name   => 'MY_PIPE1',
        attribute_name  => 'format',
        attribute_value => JSON_OBJECT('type' value 'json', 'columnpath' value '["$.NAME", "$.AGE", "$.SALARY"]')
    );
END;
/

使用時戳資料欄建立及設定匯出的管線

您可以建立匯出管線，將時間序列資料從您的 Autonomous Database 自動匯出至物件存放區。

您可以使用此匯出管線選項指定表格或 SQL 查詢，以及一個含有時戳的資料欄，供管線用來追蹤上次上傳的時間。您可以使用匯出管線來共用資料供其他應用程式使用，或將資料儲存至物件存放區。

使用匯出管線時，管線套件會使用 DBMS_CLOUD.EXPORT_DATA 來匯出資料。

匯出管線會將資料從您的 Autonomous Database 匯出至物件存放區。建立匯出管線時，管線會定期執行，並將資料置於物件存放區。

建立管線以將資料匯出至物件存放區。

BEGIN
     DBMS_CLOUD_PIPELINE.CREATE_PIPELINE(
        pipeline_name=>'EXP_PIPE1',
        pipeline_type=>'EXPORT',
        description=>'Export time series metrics to object store');
END;
/

如需詳細資訊，請參閱CREATE_PIPELINE 程序。

建立證明資料物件以存取您要匯出資料檔的目的地物件存放區位置。

您可以使用屬性 credential_name 指定管線目的地位置的證明資料。如果您未在下一個步驟中提供 credential_name，則 credential_name 值會設為 NULL。當 location 屬性為公用或預先認證的 URL 時，您可以使用預設的 NULL 值。

如需詳細資訊，請參閱CREATE_CREDENTIAL 程序。
設定匯出管線屬性。

當您指定 table_name 參數時，表格資料列會匯出至物件存放區。當您指定 query 參數時，查詢會指定 SELECT 敘述句，以便只將必要的資料匯出至物件存放區。
- 使用 table_name 參數：
```
BEGIN
     DBMS_CLOUD_PIPELINE.SET_ATTRIBUTE(
       pipeline_name => 'EXP_PIPE1',
       attributes    => JSON_OBJECT('credential_name' VALUE 'OBJECT_STORE_CRED',
          'location' VALUE 'https://objectstorage.us-phoenix-1.oraclecloud.com/n/namespace-string/b/bucketname/o/',
          'table_name' VALUE 'metric_table',
          'key_column' VALUE 'metric_time',
          'format' VALUE '{"type": "json"}',
          'priority' VALUE 'MEDIUM',
          'interval' VALUE '20')
  );
END;
/
```
- 使用 query 參數：
```
BEGIN
     DBMS_CLOUD_PIPELINE.SET_ATTRIBUTE(
       pipeline_name => 'EXP_PIPE1',
       attributes    => JSON_OBJECT('credential_name' VALUE 'OBJECT_STORE_CRED',
           'location' VALUE 'https://objectstorage.us-phoenix-1.oraclecloud.com/n/namespace-string/b/bucketname/o/',
           'query' VALUE 'SELECT * from metrics_table',
           'key_column' VALUE 'metric_time',
           'format' VALUE '{"type": "json"}',
           'priority' VALUE 'MEDIUM',
           'interval' VALUE '20')
  );
END;
/
```
其中 credential_name 是您在上一個步驟中建立的證明資料。

必須設定下列屬性，才能執行匯出管線：
- location：指定目的地物件存放區位置。您指定的 location 適用於每個管線一個 table_name。
- table_name：指定資料庫中包含您要匯出之資料的表格 (需要 table_name 參數或 query 參數)。
- query：指定要在資料庫中執行的查詢，提供您要匯出的資料 (需要 table_name 參數或 query 參數)。
- format：描述您要匯出之資料的格式。
  
  如需詳細資訊，請參閱 EXPORT_DATA 的 DBMS_CLOUD 套件格式選項。
priority 值決定從資料庫擷取資料的平行程度。

interval 值指定管線工作連續執行之間的時間間隔 (分鐘)。預設 interval 為 15 分鐘。

如需有關管線屬性的詳細資訊，請參閱 DBMS_CLOUD_PIPELINE 屬性。
建立管線之後，您可以測試管線或啟動管線：
- 測試管線
- 啟動管道

建立並設定管線以匯出查詢結果 (沒有時戳)

您可以建立匯出管線，將資料從您的 Autonomous Database 自動匯出至物件存放區。您可以使用此匯出管線選項指定管線定期執行的 SQL 查詢，以將資料匯出至物件存放區。您可以使用此匯出選項來共用來自 Autonomous Database 的最新資料，以物件儲存其他應用程式，以使用資料。

匯出管線會將資料從您的 Autonomous Database 匯出至物件存放區。建立匯出管線時，管線會定期執行，並將資料置於物件存放區。

建立管線以將資料匯出至物件存放區。

BEGIN
     DBMS_CLOUD_PIPELINE.CREATE_PIPELINE(
        pipeline_name=>'EXP_PIPE2',
        pipeline_type=>'EXPORT',
        description=>'Export query results to object store.');
END;
/

如需詳細資訊，請參閱CREATE_PIPELINE 程序。

建立證明資料物件以存取您要匯出資料檔的目的地物件存放區位置。

您可以使用屬性 credential_name 指定管線目的地位置的證明資料。如果您未在下一個步驟中提供 credential_name，則 credential_name 值會設為 NULL。當 location 屬性為公用或預先認證的 URL 時，您可以使用預設的 NULL 值。

如需詳細資訊，請參閱CREATE_CREDENTIAL 程序。
設定匯出管線屬性。
```
BEGIN
     DBMS_CLOUD_PIPELINE.SET_ATTRIBUTE(
       pipeline_name => 'EXP_PIPE2',
       attributes    => JSON_OBJECT(
          'credential_name' VALUE 'OBJECT_STORE_CRED',
          'location' VALUE 'https://objectstorage.us-phoenix-1.oraclecloud.com/n/namespace-string/b/bucketname/o/',
          'query' VALUE 'SELECT * FROM table_name',
          'format' VALUE '{"type": "json"}',
          'priority' VALUE 'MEDIUM',
          'interval' VALUE '20')
  );
END;
/
```
其中 credential_name 是您在上一個步驟中建立的證明資料。

必須設定下列屬性，才能執行匯出管線：
- location：指定目的地物件存放區位置。
- query：指定要在提供所匯出資料的資料庫中執行的查詢。
- format：描述您要匯出之資料的格式。
  
  如需詳細資訊，請參閱 EXPORT_DATA 的 DBMS_CLOUD 套件格式選項。
priority 值決定從資料庫擷取資料的平行程度。

interval 值指定管線工作連續執行之間的時間間隔 (分鐘)。預設 interval 為 15 分鐘。

如需有關管線屬性的詳細資訊，請參閱 DBMS_CLOUD_PIPELINE 屬性。
建立管線之後，您可以測試管線或啟動管線：
- 測試管線
- 啟動管道

測試管線

使用 RUN_PIPELINE_ONCE 可視需要執行一次管線，而不建立排定的工作。

RUN_PIPELINE_ONCE 可在啟動管線之前測試管線。執行管線一次以測試管線並檢查管線是否如預期運作之後，請使用 RESET_PIPELINE 將管線的狀態 (在執行 RUN_PIPELINE_ONCE 之前的狀態) 重設為該狀態。

建立管線。

請參閱建立及設定用於載入資料的管線以瞭解詳細資訊。

執行一次管線以測試管線。

BEGIN
    DBMS_CLOUD_PIPELINE.RUN_PIPELINE_ONCE(
        pipeline_name => 'MY_PIPE1'
);
END;
/

如需詳細資訊，請參閱RUN_PIPELINE_ONCE 程序。

執行任何必要的檢查，以確認管線如預期般運作。

請參閱監控及疑難排解管線以瞭解詳細資訊。

重設管線。

BEGIN  
   DBMS_CLOUD_PIPELINE.RESET_PIPELINE(
     pipeline_name => 'MY_PIPE1',
     purge_data => TRUE
);
END;
/

如需詳細資訊，請參閱RESET_PIPELINE 程序。

標題與著作權資訊

Oracle 和 (或) 其關係企業。