def dolphin_env()

in ambari_plugin-2.0.6/common-services/DOLPHIN/2.0.6/package/scripts/dolphin_env.py [0:0]


def dolphin_env():
    import params # import 导入params.py文件

    Directory(params.dolphin_pidfile_dir, # Directory执行文件夹操作
              mode=0777,
              owner=params.dolphin_user,
              group=params.dolphin_group,
              create_parents=True # 父目录不存在时一起创建
              )
    Directory(params.dolphin_log_dir,
              mode=0777,
              owner=params.dolphin_user,
              group=params.dolphin_group,
              create_parents=True
              )
    Directory(params.dolphin_conf_dir,
              mode=0777,
              owner=params.dolphin_user,
              group=params.dolphin_group,
              create_parents=True
              )

    Directory(params.dolphin_common_map['data.basedir.path'],
              mode=0777,
              owner=params.dolphin_user,
              group=params.dolphin_group,
              create_parents=True
              )

    # 做配置文件的覆盖
    File(format(params.dolphin_env_path), # File表示执行文件操作
         mode=0777,
         content=InlineTemplate(params.dolphin_env_content),
         owner=params.dolphin_user,
         group=params.dolphin_group
         )

    File(format(params.dolphin_bin_dir + "/dolphinscheduler-daemon.sh"),
               mode=0755,
               content=Template("dolphin-daemon.sh.j2"),
               owner=params.dolphin_user,
               group=params.dolphin_group
               )

    File(format(params.dolphin_conf_dir + "/master.properties"),
         mode=0755,
         content=Template("master.properties.j2"),
         owner=params.dolphin_user,
         group=params.dolphin_group
         )

    File(format(params.dolphin_conf_dir + "/worker.properties"),
         mode=0755,
         content=Template("worker.properties.j2"),
         owner=params.dolphin_user,
         group=params.dolphin_group
         )

    File(format(params.dolphin_conf_dir + "/application-api.properties"),
         mode=0755,
         content=Template("application-api.properties.j2"),
         owner=params.dolphin_user,
         group=params.dolphin_group
         )

    File(format(params.dolphin_conf_dir + "/common.properties"),
         mode=0755,
         content=Template("common.properties.j2"),
         owner=params.dolphin_user,
         group=params.dolphin_group
         )

    File(format(params.dolphin_conf_dir + "/quartz.properties"),
         mode=0755,
         content=Template("quartz.properties.j2"),
         owner=params.dolphin_user,
         group=params.dolphin_group
         )

    File(format(params.dolphin_conf_dir + "/registry.properties"),
         mode=0755,
         content=Template("registry.properties.j2"), #
         owner=params.dolphin_user,
         group=params.dolphin_group
         )

    File(format(params.dolphin_conf_dir + "/application-mysql.yaml"),
         mode=755,
         content=Template("application-mysql.yaml.j2"), #  File表示执行文件操作,将这个文件的内容进行模版替换
         owner=params.dolphin_user,
         group=params.dolphin_group
         )