一、目的
由于Hive处理好的结果数据要同步到ClickHouse中,因此需要在在海豚调度器中执行ClickHouse的ADS层的建库建表语句
二、执行步骤
(一)情形一:ClickHouse和海豚在同一服务器上
1、直接在海豚中创建执行SQL文件脚本的工作流
(1)第一步,在资源中心上传ADS层的建库建表SQL文件
(2)第二步,在项目里建工作流,添加运行SQL文件的脚本
#! /bin/bash
source /etc/profile
clickhouse-client --user default --password hurys@123 -d default --multiquery <basic_ads.sql
(3)第三步,保存并执行工作流
(二)情形二:ClickHouse和海豚不在同一服务器上
1、在ClickHouse数据源里执行建库建表SQL语句(一个任务一条SQL)
(1)第一步,在海豚中创建ClickHouse的数据源
(2)第二步,创建海豚工作流,执行建库建表SQL
注意:建库和建表分开,然后一个任务一条建表SQL
A、建库案例
create database if not exists hurys_dc_ads;
B、建表案例
--1.2 统计数据流量表——动态分区——1小时周期
create table if not exists hurys_dc_ads.ads_statistics_volume_1hour(
device_no String comment '设备编号',
name Nullable(String) comment '场景',
lane_no Nullable(int) comment '车道编号',
lane_direction Nullable(String) comment '车道流向',
section_no Nullable(Float32) comment '断面编号',
coil_no Nullable(Float32) comment '线圈编号',
direction Nullable(String) comment '雷达朝向',
sum_volume_hour Nullable(int) comment '每小时总流量',
start_time DateTime comment '开始时间',
end_time DateTime comment '结束时间',
day Date comment '日期'
)ENGINE = MergeTree
PARTITION BY (day)
PRIMARY KEY day
order by day
TTL day + toIntervalMonth(12)
SETTINGS index_granularity = 8192;
(3)第三步,保存并执行工作流
对于海豚调度器和ClickHouse在不在同一服务器上,ADS层建库建表语句会有不同的工作流配置方式。文章来源:https://www.toymoban.com/news/detail-723376.html
注意,由于海豚调度器中的ClickHouse数据源,一个任务只能一条SQL语句,即一个; 因此不能把多个建表SQL放在一个任务中,否则会运行报错,因此海豚中的ClickHouse没有区分分段执行文章来源地址https://www.toymoban.com/news/detail-723376.html
到了这里,关于一百八十九、ClickHouse——在海豚调度器中执行ClickHouse建库建表语句的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!