taskctl命令行类（sh、exe、python新增scp）插件升级扩展

浏览: 1844

转载自： http://www.taskctl.com/forum/detail_129.html

    上次写了一个帖子 TASKCTL中不使用代理，通过ssh免密连接执行远程脚本配置（SSH插件扩展）http://www.taskctl.com/forum/detail_122.html 。写完后发现，其实在原本的sh作业类型上改造一下就可以了，同时延伸到以前是用command执行方式的作业类型，都可以适当扩展，命令行类插件升级20171110.rar就是 sh、exe、python的插件和新增拷贝一些小文件的scp作业类型。插件中主要使用的ssh免密及其相关的几个参数和bash的几种模式，这个只是一个基础版本，如果有特殊的需求基于上面的插件改造一下就可以了。下面是摘抄了原网页上写法写的一个sh脚本的扩展，其他几个类似。

   使用TASKCTL调度服务时，如果需要跨用户或者跨服务器调度可以通过安装taskctl的代理来实现，但有时需要执行作业的服务器上仅仅只有几个脚本或者一两个可执行程序，此时再部署代理，就显得有点得不偿失了。我们知道TASKCTL支持任意作业类型的扩展，所以我们是不是可以考虑通过SSH远程连接来扩展这些插件，使其能执行这些远程少量的脚本程序。

    下面是通过扩展TASKCTL用ssh连接来支持调度远程作业的步骤，一方面解决一些朋友迫切的调度需求，另一方面抛砖引玉，让大家能够在TASKCTL中扩展更多的适应自己需求的作业插件。

    下面编写的过程参照 http://www.taskctl.com/forum/detail_33.html 。

    1、首先在服务端的$TASKCTLDIR/src/plugin/sh/shell/目录中新增cprunsh.sh作业插件，实际上就是一个shell程序，代码如下：

#!/bin/sh

#------------------------------------------------------------------------------

#	功能: [ssh方式]执行[远程]Shell脚本驱动插件程序

#

#	更新日志：20171030 由最开始的集成转换为插件，增强扩展原只能执行当前用户可读的 shell 脚本，

#		通过ssh协议，在免密的情况下可以执行本机不同用户和非本机的其他用户

#

#	参数: 

#		1. progname   脚本的全路径名称

#		2. para       脚本的入口参数，格式为 para1 para2 ...

#		3. exppara    对应相应脚本的exppara属性，为脚本文件所在用户，当该参数为空时，默认为当前用户,如果不是当前用户时，为远程连接IP地址和用户名

#			sip=172.22.1.1     ssh远程IP地址

#			sport=9527         ssh远程连接端口

#			suser=taskctl      ssh远程用户

#	返回值: 脚本执行后的实际返回值

#	

#	流程模式代码任务定义举例:

#	1、默认2个输入参数的安装用户可执行的服务器上的sh脚本(如果参数多个，以此类推)

#	<sh>

#		<name>job1</name>

#		<progname>/home/taskctl/test.sh</progname> 

#		<para>para1 para2</para>

#	</sh>

#	2、在同一台服务器上的其他用户可执行，当前节点安装用户不可执行sh脚本，当前用户和目标用户做了ssh免密(如果参数多个，以此类推)

#	<sh>

#		<name>job1</name>

#		<progname>/home/username/test.sh</progname> 

#		<para>para1 para2</para>

#		<exppara>[sport=22,]suser=taskctl</exppara>

#	</sh>

#	3、不同服务器上，但都是shell作业，当前节点安装用户已经做了ssh免密(如果参数多个，以此类推)

#	<sh>

#		<name>job1</name>

#		<progname>/home/username/test.sh</progname> 

#		<para>para1 para2</para>

#		<exppara>sip=172.22.1.1,[sport=22,]suser=taskctl</exppara>

#	</sh>

#

#------------------------------------------------------------------------------



if [ $# -ne 3 ]

then

    echo "Param error !"

    echo "Usage: $0 progname para expara"

    exit 126

fi



#------------------------------------------------------------------------------

#      第一步： 接收参数

#------------------------------------------------------------------------------ 

ProgName=$1

Para=$2

ExpPara=$3



#------------------------------------------------------------------------------

#      第二步： 解析 exppara

#------------------------------------------------------------------------------ 

function getValue(){

	if [ $# -ne 2 ] 

	then

		echo "......."

		exit 1

	fi

	

	str=`echo $2|awk -v record=$1 'BEGIN {

		split(record,myarray,",");

		

	}

	END{

		for (i in myarray){

			if (myarray[i]~$1){

				if ( index(myarray[i],$1) == 1){

					print myarray[i];

					break;

				}

			}

			}

	}

	'`

	echo $str|awk -F"=" '{print $2}'

}



ExpPara=`echo $ExpPara`    #此处为了去前后空格,以便判断是否真正有入口参数

#通过判断 exppara 是否为空，决定是直接执行sh还是走ssh通道

#直接执行

if [ ! -n "$ExpPara" ] 

then

	sh $ProgName $Para

	ret=$?

	exit $ret

fi

#走ssh通道

sip=`getValue $ExpPara sip`

#通过判断 sip 是否为空，决定是直接执行本机其他用户还是远程服务器上的sh脚本

if [ ! -n "$sip" ] 

then

	sip=localhost

fi

#sport=`getValue $ExpPara sport` #默认没有修改端口 传参数的时候也没有传 先屏蔽

sport=22

suser=`getValue $ExpPara suser`



#------------------------------------------------------------------------------

#      第三步： 检测是否配置了ssh免密连接

#------------------------------------------------------------------------------

ssh -o ConnectTimeout=5 -o NumberOfPasswordPrompts=0 -o StrictHostKeyChecking=no -p $sport $suser@$sip 'pwd' &>/dev/null

if [ $? != 0 ];then

	echo -e "\nSSH Connection failed $sip"

	echo -e "\nssh-keygen -t rsa -P ''"

	echo -e "\nssh-copy-id -p $sport $suser@$sip"

	exit 1

else

	echo -e "\nSSH connection succeeded $sip"

fi



#------------------------------------------------------------------------------

#      第四步： 运行JOB，并返回结果

#------------------------------------------------------------------------------ 

#echo "ssh -o NumberOfPasswordPrompts=0 -o StrictHostKeyChecking=no -p $sport $suser@$sip bash --login $ProgName $Para"    #此处为打印执行命令行,以便调试判断是否真正有入口参数

ssh -o NumberOfPasswordPrompts=0 -o StrictHostKeyChecking=no -p $sport $suser@$sip "bash --login $ProgName $Para"

ret=$?

exit $ret

    2、在桌面软件admin中进入"任务类型"功能中，设置ssh作业类型，如下图所示：

blob.png

    3、在桌面软件designer中设计 sh 作业如下代码片段：

<!-- 按插件的规则编写的流程设置 -->

  <sh>

    <name>MainModul_JobNode0</name>

    <progname>/home/cdchen/successjob.sh</progname>

    <para>para1 para2</para>

    <exppara>sip=192.168.0.192,suser=cdchen</exppara>

    <jobdesc>测试远程sh作业</jobdesc>

  </sh>

    4、调试测试作业是否符合预期

blob.png

推荐 0
本文由 ETL批量调度-Taskctl 创作，采用 知识共享署名-相同方式共享 3.0 中国大陆许可协议 进行许可。
转载、引用前需联系作者，并署名作者且注明文章出处。
本站文章版权归原作者及原出处所有 。内容为作者个人观点， 并不代表本站赞同其观点和对其真实性负责。本站是一个个人学习交流的平台，并不用于任何商业目的，如果有任何问题，请及时联系我们，我们将根据著作权人的要求，立即更正或者删除有关内容。本站拥有对此声明的最终解释权。

0 个评论

要回复文章请先登录或注册