本文将为您介绍如何使用DataWorks PyODPS类型的节点调用单文件第三方包。

  1. 登录DataWorks控制台,单击相应工作空间后的进入数据开发
  2. 打开相应的业务流程,右键单击MaxCompute,选择新建 > 资源 > Python新建资源
  3. 新建资源对话框中,输入资源名称,并勾选上传为ODPS资源新建资源
  4. 单击确定
  5. 在新建的Python资源内,粘贴需要引用的第三方包的代码,示例如下。
    # import os
    # print os.getcwd()
    # print os.path.abspath('.')
    # print os.path.abspath('..')
    # print os.path.abspath(os.curdir)
    
    def printname():
        print 'test2'
    print 123
    粘贴代码完成后,单击提交提交
  6. 打开相应的业务流程,右键单击MaxCompute,选择新建 > PyODPS新建PyODPS
  7. 新建节点对话框中,输入节点名称,单击提交
  8. 在节点内输入引用第三方包的代码并测试,示例如下。
    ##@resource_reference{"test2.py"}
    
    import sys 
    import os
    sys.path.append(os.path.dirname(os.path.abspath('test2.py'))) #将资源引入工作空间
    import test2 #引用资源
    test2.printname() #调用方法
    说明 ##@resource_reference{"test2.py"}用于引用之前新建的Python资源,该语句必须添加。
  9. 完成上述操作后,单击运行测试您的代码。您可以在下方的日志中查看运行结果。运行