本文为您介绍如何基于Dataphin构建Python类型的离线计算任务。
前提条件
背景信息
Python任务中引用到的Python文件需要提前创建,因此您在资源管理中先上传Python文件,然后在Python任务中引用。
操作步骤
- 登录Dataphin控制台。
- 在Dataphin控制台页面,选择工作区地域后,单击进入Dataphin>>。
您可以通过以下方式,快速进入工作区:
- 选择工作区地域后,单击快速开始相关工作区域中相应的功能模块。
- 选择工作区地域后,单击快速进入研发项目后的Dev、Prod或Basic页签,选择相应的项目。
- 进入离线计算任务页面。
- 在Dataphin首页,单击顶部菜单栏的研发。
- 在数据开发页面,单击项目名称后的
图标后,单击Dev或Basic页签,选择数据开发的项目空间(Dev或Basic项目)。
如果您当前访问的是Dev或Basic项目,且项目空间为您的数据开发空间,则不需要选择项目空间。 - 可选:在数据开发页面,单击数据处理页签。
如果进入数据开发页面后,系统默认进入数据处理页签,则无需再次单击数据处理页签。
- 在数据处理页签,单击左侧导航栏
离线计算任务图标。
- 在离线计算任务页面,单击
图标后,选择PYTHON。
- 编写并运行代码。
- 在新建文件对话框,配置参数。
参数 描述 名称 填写代码任务的名称,例如Python。 调度类型 选择任务的调度类型。调度类型包括: - 周期性节点,自动参与系统的周期性调度。
- 手动节点,需要手动触发任务的运行。
描述 填写对任务的简单描述。 选择目录 选择代码任务的目录。 - 单击确定。
- 在Python任务代码编写页面,进行编写代码任务。
代码示例如下。
建议您在Python文件前两行对编码进行主动注释 ,防止执行代码时使用系统编码,导致执行结果报错。#!/usr/bin/python # -*- coding: latin-1 -*- import time import datetime import base64 import hashlib import json import sys import csv from odps import ODPS def main(): print "Hello World"
- 代码编写完成后,单击页面右上方的刷新。
- 单击页面右上角的执行,运行代码。
- 在新建文件对话框,配置参数。
- 可选:配置调度参数。
- 如果离线计算任务的调度类型为周期性节点,则需要配置调度参数,详情请参见调度配置。
- 如果离线计算任务的调度类型为手动节点,需要手动触发任务的调度。
- 在代码编写页面,保存并提交Python任务。
- 单击页面右上方的
图标,保存代码。
- 单击页面右上方的
图标,提交代码。
- 单击页面右上方的
- 可选:发布Python任务。
- 如果您的开发模式是Dev-Prod模式,则需要发布Python任务,详情请参见发布任务。
- 如果您的开发模式是Basic模式,则提交成功后的Python任务,即可参与生产环境的调度。
在文档使用中是否遇到以下问题
更多建议
匿名提交