在 DataWorks 中创建 ODPS SQL 节点,可以按照以下步骤进行操作:
登录 DataWorks 控制台,在左侧导航栏中选择您要操作的项目,进入项目首页。
在项目首页中,点击左侧导航栏中的 "数据开发",进入数据开发页面。
在数据开发页面中,点击右上方的 "新建" 按钮,选择 "ODPS SQL",进入 ODPS SQL 节点的创建页面。
在 ODPS SQL 节点的创建页面中,输入节点名称和描述信息,并选择要使用的 ODPS 账号和数据源。在 SQL 编辑器中编写 SQL 语句,可以使用智能提示、代码高亮和调试等功能进行开发和调试。
在 SQL 编辑器中编写完 SQL 语句后,可以点击 "运行" 按钮进行测试和调试。在运行前,可以选择运行的资源组、优先级和资源配额等参数。
运行成功后,可以查看 SQL 执行结果和日志信息,并进行后续的数据开发和数据流转等操作。
以下是在DataWorks中创建ODPS SQL节点的一般操作步骤:
登录DataWorks:使用你的账号登录DataWorks工作台。
创建项目:如果还没有项目,可以先创建一个新项目。在左侧导航栏中点击"项目列表",然后点击"新建项目",填写项目名称和描述等信息,并创建项目。
进入项目工作区:在项目列表中找到你创建的项目,在项目名称旁边点击"进入"按钮,进入到项目的工作区。
创建工作流:在项目工作区中,点击"工作流设计",然后点击右上角的"新建工作流",填写工作流名称和描述等信息,并创建工作流。
添加ODPS SQL节点:在工作流设计页面,点击左侧的"组件"菜单,找到"ODPS SQL"节点,将其拖放到工作流画布上。
配置ODPS SQL节点:选中添加的ODPS SQL节点,在右侧的属性面板中配置节点的相关信息,包括节点名称、SQL脚本、输入输出表等。
连接节点:根据需要,在工作流中添加其他节点,并使用连线将这些节点连接起来,以定义数据流向和依赖关系。
提交工作流:完成节点配置和连线后,点击工作流设计页面顶部的"保存"按钮保存工作流,然后点击右上角的"提交"按钮提交工作流。
运行工作流:在提交后,可以点击右上角的"运行"按钮来执行工作流中的节点。根据设置,ODPS SQL节点将会执行对应的SQL脚本,并处理输入输出表的数据。
进入数据开发页面。登录DataWorks控制台。在左侧导航栏,单击工作空间列表。选择工作空间所在地域后,单击相应工作空间后的进入数据开发。鼠标悬停至
图标,单击MaxCompute > ODPS SQL。您也可以找到相应的业务流程,右键单击MaxCompute,选择新建 > ODPS SQL。在新建节点对话框中,输入节点名称,并选择目标文件夹。说明 节点名称必须是大小写字母、中文、数字、下划线(_)和小数点(.),且不能超过128个字符。单击提交。在节点的编辑页面,编辑并运行代码。新建节点成功后,编写符合语法的ODPS SQL代码,SQL语法请参见SQL概述。说明 由于国际标准化组织发布的中国时区信息调整,通过DataWorks执行相关SQL时,日期显示某些时间段会存在时间差异:1900~1928年的日期时间差异5分52秒,1900年之前的日期时间差异9秒。DataWorks不允许节点代码中仅包含set语句。如果您需要运行SET语句,可以和其它SQL语句一起执行,如下所示。
set project odps.sql.allow.fullscan=true;select 1;SET语句的详情请参见SET操作。以创建一张表并向表中插入数据,查询结果为例,操作如下:创建一张表test1。CREATE TABLE IF NOT EXISTS test1( id BIGINT COMMENT '' ,name STRING COMMENT '' ,age BIGINT COMMENT '' ,sex STRING COMMENT '');插入准备好的数据。INSERT INTO test1 VALUES (1,'张三',43,'男') ;INSERT INTO test1 VALUES (1,'李四',32,'男') ;INSERT INTO test1 VALUES (1,'陈霞',27,'女') ;INSERT INTO test1 VALUES (1,'王五',24,'男') ;INSERT INTO test1 VALUES (1,'马静',35,'女') ;INSERT INTO test1 VALUES
https://help.aliyun.com/document_detail/137510.html,此回答整理自钉群“DataWorks交流群(答疑@机器人)”
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
DataWorks基于MaxCompute/Hologres/EMR/CDP等大数据引擎,为数据仓库/数据湖/湖仓一体等解决方案提供统一的全链路大数据开发治理平台。