使用限制

只有Flink計算引擎VVR 3.0.2及以上版本支持使用Flink SQL寫入云數據庫ClickHouse。

前提條件

• 已在云數據庫ClickHouse中創建表。更多信息，請參見創建表。

• 已在云數據庫ClickHouse中設置白名單。更多信息，請參見設置白名單。

• 已開通Flink全托管。更多信息，請參見開通Flink全托管。

操作步驟

1. 登錄Flink全托管控制臺，新建作業。

   1. 登錄實時計算控制臺。

   2. 在Flink全托管頁簽，單擊目標工作空間操作列下的控制臺。

   3. 在SQL開發頁面，單擊新建。

   4. 單擊空白的流作業草稿。

      Flink全托管為您提供了豐富的SQL代碼模板和數據同步模板，每種模板都為您提供了使用場景、代碼示例和使用指導。您也可以直接單擊對應的模板進行使用，快速實現您的業務邏輯，詳情請參見代碼模板和數據同步模板。

   5. 單擊下一步。

   6. 在新建文件對話框，填寫作業配置信息。

      作業參數	說明
      文件名稱	作業的名稱。 說明 作業名稱在當前項目中必須保持唯一。
      存儲位置	指定該作業的存儲位置。 您還可以在現有文件夾右側，單擊圖標，新建子文件夾。
      引擎版本	當前作業使用的Flink的引擎版本。引擎版本號含義、版本對應關系和生命周期重要時間點詳情請參見引擎版本介紹。

   7. 單擊創建。

2. 編寫并執行代碼。

   1. 創建源表、結果表，并將源表數據插入到結果表中。

      --創建源表sls_test_single_local。
      CREATE TEMPORARY TABLE sls_test_single_local (
        id INT,
        name VARCHAR,
        age BIGINT,
        rate FLOAT
      ) WITH (
        'connector' = 'datagen',
        'rows-per-second' = '50'
      );
      --創建結果表clickhouse_output。
      CREATE TEMPORARY TABLE clickhouse_output (
        id INT,
        name VARCHAR,
        age BIGINT,
        rate FLOAT
      ) WITH (
        'connector' = 'clickhouse',
        'url' = 'jdbc:clickhouse://demo.aliyuncs.com:8123',
        'userName' = 'test',
        'password' = '280226Ck',
        'tableName' = 'sls_test_single_local'
      );
      --將源表數據插入到結果表。
      INSERT INTO clickhouse_output
      SELECT 
        id,
        name,
        age,
        rate
      FROM sls_test_single_local;

      說明

      創建結果表的語法說明，請參見ClickHouse結果表。

   2. 單擊保存。

   3. 單擊驗證。

   4. 單擊上線。

   5. 在彈出的上線確認窗口中單擊確認，將作業發布至生產環境。

   6. 上線成功后，在彈出的上線成功，請前往運維查看詳情中單擊運維。

3. 在作業運維頁面，啟動作業。

   1. 單擊右上方啟動。

   2. 在彈出的作業啟動配置頁面，單擊確認啟動。

4. 在云數據庫ClickHouse中查詢表。

   1. 登錄云數據庫ClickHouse控制臺。

   2. 在頁面左上角，選擇目標集群所在的地域。

   3. 在集群列表頁面，選擇目標集群對應類型的實例列表，單擊目標集群ID。

   4. 在集群信息頁面，單擊右上方導航欄的登錄數據庫。

   5. 在登錄實例頁面，輸入數據庫賬號和密碼，單擊登錄。

   6. 輸入查詢語句并單擊執行（F8）。本文使用下面的示例語句。

      select * from db01.sls_test_single_local;

      查詢結果如下。