123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445 |
- CREATE SEQUENCE "xxl_job_group_id_seq"
- INCREMENT 1
- MINVALUE 1
- MAXVALUE 2147483647
- START 1
- CACHE 1;
- SELECT setval('"xxl_job_group_id_seq"', 2, true);
- CREATE SEQUENCE "xxl_job_info_id_seq"
- INCREMENT 1
- MINVALUE 1
- MAXVALUE 2147483647
- START 1
- CACHE 1;
- SELECT setval('"xxl_job_info_id_seq"', 8, true);
- CREATE SEQUENCE "xxl_job_log_id_seq"
- INCREMENT 1
- MINVALUE 1
- MAXVALUE 2147483647
- START 1
- CACHE 1;
- CREATE SEQUENCE "xxl_job_logglue_id_seq"
- INCREMENT 1
- MINVALUE 1
- MAXVALUE 2147483647
- START 1
- CACHE 1;
- CREATE SEQUENCE "xxl_job_log_report_id_seq"
- INCREMENT 1
- MINVALUE 1
- MAXVALUE 2147483647
- START 1
- CACHE 1;
- CREATE SEQUENCE "xxl_job_registry_id_seq"
- INCREMENT 1
- MINVALUE 1
- MAXVALUE 2147483647
- START 1
- CACHE 1;
- CREATE SEQUENCE "xxl_job_user_id_seq"
- INCREMENT 1
- MINVALUE 1
- MAXVALUE 2147483647
- START 1
- CACHE 1;
- SELECT setval('"xxl_job_user_id_seq"', 2, true);
- CREATE TABLE "xxl_job_group" (
- "id" int4 NOT NULL DEFAULT nextval('xxl_job_group_id_seq'::regclass),
- "app_name" varchar(64) COLLATE "pg_catalog"."default" NOT NULL,
- "title" varchar(12) COLLATE "pg_catalog"."default" NOT NULL,
- "address_type" int2 NOT NULL,
- "address_list" text COLLATE "pg_catalog"."default",
- "update_time" timestamp(6)
- )
- ;
- COMMENT ON COLUMN "xxl_job_group"."app_name" IS '执行器AppName';
- COMMENT ON COLUMN "xxl_job_group"."title" IS '执行器名称';
- COMMENT ON COLUMN "xxl_job_group"."address_type" IS '执行器地址类型:0=自动注册、1=手动录入';
- COMMENT ON COLUMN "xxl_job_group"."address_list" IS '执行器地址列表,多地址逗号分隔';
- CREATE TABLE "xxl_job_info" (
- "id" int4 NOT NULL DEFAULT nextval('xxl_job_info_id_seq'::regclass),
- "job_group" int4 NOT NULL,
- "job_desc" varchar(255) COLLATE "pg_catalog"."default" NOT NULL,
- "add_time" timestamp(6),
- "update_time" timestamp(6),
- "author" varchar(64) COLLATE "pg_catalog"."default",
- "alarm_email" varchar(255) COLLATE "pg_catalog"."default",
- "schedule_type" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
- "schedule_conf" varchar(128) COLLATE "pg_catalog"."default",
- "misfire_strategy" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
- "executor_route_strategy" varchar(50) COLLATE "pg_catalog"."default",
- "executor_handler" varchar(255) COLLATE "pg_catalog"."default",
- "executor_param" varchar(512) COLLATE "pg_catalog"."default",
- "executor_block_strategy" varchar(50) COLLATE "pg_catalog"."default",
- "executor_timeout" int4 NOT NULL,
- "executor_fail_retry_count" int4 NOT NULL,
- "glue_type" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
- "glue_source" text COLLATE "pg_catalog"."default",
- "glue_remark" varchar(128) COLLATE "pg_catalog"."default",
- "glue_updatetime" timestamp(6),
- "child_jobid" varchar(255) COLLATE "pg_catalog"."default",
- "trigger_status" int2 NOT NULL,
- "trigger_last_time" int8 NOT NULL,
- "trigger_next_time" int8 NOT NULL
- )
- ;
- COMMENT ON COLUMN "xxl_job_info"."job_group" IS '执行器主键ID';
- COMMENT ON COLUMN "xxl_job_info"."author" IS '作者';
- COMMENT ON COLUMN "xxl_job_info"."alarm_email" IS '报警邮件';
- COMMENT ON COLUMN "xxl_job_info"."schedule_type" IS '调度类型';
- COMMENT ON COLUMN "xxl_job_info"."schedule_conf" IS '调度配置,值含义取决于调度类型';
- COMMENT ON COLUMN "xxl_job_info"."misfire_strategy" IS '调度过期策略';
- COMMENT ON COLUMN "xxl_job_info"."executor_route_strategy" IS '执行器路由策略';
- COMMENT ON COLUMN "xxl_job_info"."executor_handler" IS '执行器任务handler';
- COMMENT ON COLUMN "xxl_job_info"."executor_param" IS '执行器任务参数';
- COMMENT ON COLUMN "xxl_job_info"."executor_block_strategy" IS '阻塞处理策略';
- COMMENT ON COLUMN "xxl_job_info"."executor_timeout" IS '任务执行超时时间,单位秒';
- COMMENT ON COLUMN "xxl_job_info"."executor_fail_retry_count" IS '失败重试次数';
- COMMENT ON COLUMN "xxl_job_info"."glue_type" IS 'GLUE类型';
- COMMENT ON COLUMN "xxl_job_info"."glue_source" IS 'GLUE源代码';
- COMMENT ON COLUMN "xxl_job_info"."glue_remark" IS 'GLUE备注';
- COMMENT ON COLUMN "xxl_job_info"."glue_updatetime" IS 'GLUE更新时间';
- COMMENT ON COLUMN "xxl_job_info"."child_jobid" IS '子任务ID,多个逗号分隔';
- COMMENT ON COLUMN "xxl_job_info"."trigger_status" IS '调度状态:0-停止,1-运行';
- COMMENT ON COLUMN "xxl_job_info"."trigger_last_time" IS '上次调度时间';
- COMMENT ON COLUMN "xxl_job_info"."trigger_next_time" IS '下次调度时间';
- CREATE TABLE "xxl_job_lock" (
- "lock_name" varchar(50) COLLATE "pg_catalog"."default" NOT NULL
- )
- ;
- COMMENT ON COLUMN "xxl_job_lock"."lock_name" IS '锁名称';
- CREATE TABLE "xxl_job_log" (
- "id" int4 NOT NULL DEFAULT nextval('xxl_job_log_id_seq'::regclass),
- "job_group" int4 NOT NULL,
- "job_id" int4 NOT NULL,
- "executor_address" varchar(255) COLLATE "pg_catalog"."default",
- "executor_handler" varchar(255) COLLATE "pg_catalog"."default",
- "executor_param" varchar(512) COLLATE "pg_catalog"."default",
- "executor_sharding_param" varchar(20) COLLATE "pg_catalog"."default",
- "executor_fail_retry_count" int4 NOT NULL DEFAULT 0,
- "trigger_time" timestamp(6),
- "trigger_code" int4 NOT NULL,
- "trigger_msg" text COLLATE "pg_catalog"."default",
- "handle_time" timestamp(6),
- "handle_code" int4 NOT NULL,
- "handle_msg" text COLLATE "pg_catalog"."default",
- "alarm_status" int2 NOT NULL DEFAULT 0
- )
- ;
- COMMENT ON COLUMN "xxl_job_log"."job_group" IS '执行器主键ID';
- COMMENT ON COLUMN "xxl_job_log"."job_id" IS '任务,主键ID';
- COMMENT ON COLUMN "xxl_job_log"."executor_address" IS '执行器地址,本次执行的地址';
- COMMENT ON COLUMN "xxl_job_log"."executor_handler" IS '执行器任务handler';
- COMMENT ON COLUMN "xxl_job_log"."executor_param" IS '执行器任务参数';
- COMMENT ON COLUMN "xxl_job_log"."executor_sharding_param" IS '执行器任务分片参数,格式如 1/2';
- COMMENT ON COLUMN "xxl_job_log"."executor_fail_retry_count" IS '失败重试次数';
- COMMENT ON COLUMN "xxl_job_log"."trigger_time" IS '调度-时间';
- COMMENT ON COLUMN "xxl_job_log"."trigger_code" IS '调度-结果';
- COMMENT ON COLUMN "xxl_job_log"."trigger_msg" IS '调度-日志';
- COMMENT ON COLUMN "xxl_job_log"."handle_time" IS '执行-时间';
- COMMENT ON COLUMN "xxl_job_log"."handle_code" IS '执行-状态';
- COMMENT ON COLUMN "xxl_job_log"."handle_msg" IS '执行-日志';
- COMMENT ON COLUMN "xxl_job_log"."alarm_status" IS '告警状态:0-默认、1-无需告警、2-告警成功、3-告警失败';
- CREATE TABLE "xxl_job_log_report" (
- "id" int4 NOT NULL DEFAULT nextval('xxl_job_log_report_id_seq'::regclass),
- "trigger_day" timestamp(6),
- "running_count" int4 NOT NULL,
- "suc_count" int4 NOT NULL,
- "fail_count" int4 NOT NULL,
- "update_time" timestamp(6)
- )
- ;
- COMMENT ON COLUMN "xxl_job_log_report"."trigger_day" IS '调度-时间';
- COMMENT ON COLUMN "xxl_job_log_report"."running_count" IS '运行中-日志数量';
- COMMENT ON COLUMN "xxl_job_log_report"."suc_count" IS '执行成功-日志数量';
- COMMENT ON COLUMN "xxl_job_log_report"."fail_count" IS '执行失败-日志数量';
- CREATE TABLE "xxl_job_logglue" (
- "id" int4 NOT NULL DEFAULT nextval('xxl_job_logglue_id_seq'::regclass),
- "job_id" int4 NOT NULL,
- "glue_type" varchar(50) COLLATE "pg_catalog"."default",
- "glue_source" text COLLATE "pg_catalog"."default",
- "glue_remark" varchar(128) COLLATE "pg_catalog"."default" NOT NULL,
- "add_time" timestamp(6),
- "update_time" timestamp(6)
- )
- ;
- COMMENT ON COLUMN "xxl_job_logglue"."job_id" IS '任务,主键ID';
- COMMENT ON COLUMN "xxl_job_logglue"."glue_type" IS 'GLUE类型';
- COMMENT ON COLUMN "xxl_job_logglue"."glue_source" IS 'GLUE源代码';
- COMMENT ON COLUMN "xxl_job_logglue"."glue_remark" IS 'GLUE备注';
- CREATE TABLE "xxl_job_registry" (
- "id" int4 NOT NULL DEFAULT nextval('xxl_job_registry_id_seq'::regclass),
- "registry_group" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
- "registry_key" varchar(255) COLLATE "pg_catalog"."default" NOT NULL,
- "registry_value" varchar(255) COLLATE "pg_catalog"."default" NOT NULL,
- "update_time" timestamp(6)
- )
- ;
- CREATE TABLE "xxl_job_user" (
- "id" int4 NOT NULL DEFAULT nextval('xxl_job_user_id_seq'::regclass),
- "username" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
- "password" varchar(50) COLLATE "pg_catalog"."default" NOT NULL,
- "role" int2 NOT NULL,
- "permission" varchar(255) COLLATE "pg_catalog"."default"
- )
- ;
- COMMENT ON COLUMN "xxl_job_user"."username" IS '账号';
- COMMENT ON COLUMN "xxl_job_user"."password" IS '密码';
- COMMENT ON COLUMN "xxl_job_user"."role" IS '角色:0-普通用户、1-管理员';
- COMMENT ON COLUMN "xxl_job_user"."permission" IS '权限:执行器ID列表,多个逗号分割';
- ALTER TABLE "xxl_job_group" ADD CONSTRAINT "xxl_job_group_pkey" PRIMARY KEY ("id");
- ALTER TABLE "xxl_job_info" ADD CONSTRAINT "xxl_job_info_pkey" PRIMARY KEY ("id");
- ALTER TABLE "xxl_job_lock" ADD CONSTRAINT "xxl_job_lock_pkey" PRIMARY KEY ("lock_name");
- CREATE INDEX "I_handle_code" ON "xxl_job_log" USING btree (
- "handle_code" "pg_catalog"."int4_ops" ASC NULLS LAST
- );
- CREATE INDEX "I_trigger_time" ON "xxl_job_log" USING btree (
- "trigger_time" "pg_catalog"."timestamp_ops" ASC NULLS LAST
- );
- ALTER TABLE "xxl_job_log" ADD CONSTRAINT "xxl_job_log_pkey" PRIMARY KEY ("id");
- CREATE INDEX "i_trigger_day" ON "xxl_job_log_report" USING btree (
- "trigger_day" "pg_catalog"."timestamp_ops" ASC NULLS LAST
- );
- ALTER TABLE "xxl_job_log_report" ADD CONSTRAINT "xxl_job_log_report_pkey" PRIMARY KEY ("id");
- ALTER TABLE "xxl_job_logglue" ADD CONSTRAINT "xxl_job_logglue_pkey" PRIMARY KEY ("id");
- CREATE INDEX "i_g_k_v" ON "xxl_job_registry" USING btree (
- "registry_group" COLLATE "pg_catalog"."default" "pg_catalog"."text_ops" ASC NULLS LAST,
- "registry_key" COLLATE "pg_catalog"."default" "pg_catalog"."text_ops" ASC NULLS LAST,
- "registry_value" COLLATE "pg_catalog"."default" "pg_catalog"."text_ops" ASC NULLS LAST
- );
- ALTER TABLE "xxl_job_registry" ADD CONSTRAINT "xxl_job_registry_pkey" PRIMARY KEY ("id");
- CREATE INDEX "i_username" ON "xxl_job_user" USING btree (
- "username" COLLATE "pg_catalog"."default" "pg_catalog"."text_ops" ASC NULLS LAST
- );
- ALTER TABLE "xxl_job_user" ADD CONSTRAINT "xxl_job_user_pkey" PRIMARY KEY ("id");
- INSERT INTO "xxl_job_user" ("id", "username", "password", "role", "permission") VALUES (1, 'admin', 'e10adc3949ba59abbe56e057f20f883e', 1, NULL);
- INSERT INTO "xxl_job_group" ("id", "app_name", "title", "address_type", "address_list", "update_time") VALUES (1, 'xxl-job-executor', '执行器-测试组', 0, NULL, '2022-06-05 22:21:31');
- INSERT INTO "xxl_job_info" ("id", "job_group", "job_desc", "add_time", "update_time", "author", "alarm_email", "schedule_type", "schedule_conf", "misfire_strategy", "executor_route_strategy", "executor_handler", "executor_param", "executor_block_strategy", "executor_timeout", "executor_fail_retry_count", "glue_type", "glue_source", "glue_remark", "glue_updatetime", "child_jobid", "trigger_status", "trigger_last_time", "trigger_next_time") VALUES (1, 1, 'java_script', '2022-06-07 01:48:38.21', '2022-06-07 01:57:43.739', 'zhangsan', '', 'CRON', '0/5 * * * * ?', 'DO_NOTHING', 'FIRST', '', 'https://api.vvhan.com/api/zhihu?username=uxiaohan', 'SERIAL_EXECUTION', 0, 0, 'GLUE_GROOVY', 'package com.xxl.job.service.handler;
- import com.xxl.job.core.context.XxlJobHelper;
- import com.xxl.job.core.handler.IJobHandler;
- import java.io.BufferedInputStream;
- import java.io.BufferedReader;
- import java.io.DataOutputStream;
- import java.io.InputStreamReader;
- import java.net.HttpURLConnection;
- import java.net.URL;
- import java.net.URLConnection;
- import java.util.Arrays;
- import java.util.concurrent.TimeUnit;
- public class HttpJobHandler extends IJobHandler {
- public static String sendGet(String url, String param) throws Exception{
- String result = "";
- String urlNameString = url + "?" + param;
- URL realUrl = new URL(urlNameString);
- // 打开和URL之间的连接
- URLConnection connection = realUrl.openConnection();
- // 设置通用的请求属性
- connection.setRequestProperty("accept", "*/*");
- connection.setRequestProperty("connection", "Keep-Alive");
- connection.setRequestProperty("user-agent",
- "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
- // 建立实际的连接
- connection.setRequestProperty("Accept-Charset", "utf-8");
- connection.setRequestProperty("contentType", "utf-8");
- connection.connect();
- BufferedReader inbf = new BufferedReader(new InputStreamReader(
- connection.getInputStream(),"utf-8"));
- String line;
- while ((line = inbf.readLine()) != null) {
- result += line;
- }
- inbf.close();
- return result;
- }
- @Override
- public void execute() throws Exception {
- XxlJobHelper.log("开始执行模拟请求!");
- XxlJobHelper.log("接收到的参数:{}", XxlJobHelper.getJobParam());
- // 分片参数
- int shardIndex = XxlJobHelper.getShardIndex();
- int shardTotal = XxlJobHelper.getShardTotal();
- XxlJobHelper.log("分片参数:当前分片序号 = {}, 总分片数 = {}", shardIndex, shardTotal);
- //获取调度器传递参数
- String url = XxlJobHelper.getJobParam();
- XxlJobHelper.log(sendGet(url,""));
- XxlJobHelper.log("模拟请求执行完成");
- }
- }', 'java_script', '2022-06-07 01:57:43.739', '', 0, 0, 0);
- INSERT INTO "xxl_job_info" ("id", "job_group", "job_desc", "add_time", "update_time", "author", "alarm_email", "schedule_type", "schedule_conf", "misfire_strategy", "executor_route_strategy", "executor_handler", "executor_param", "executor_block_strategy", "executor_timeout", "executor_fail_retry_count", "glue_type", "glue_source", "glue_remark", "glue_updatetime", "child_jobid", "trigger_status", "trigger_last_time", "trigger_next_time") VALUES (2, 1, 'php_script', '2022-06-07 01:49:08.833', '2022-06-07 02:02:08.743', 'zhangsan', '', 'CRON', '0/5 * * * * ?', 'DO_NOTHING', 'FIRST', '', 'https://api.vvhan.com/api/zhihu?username=uxiaohan', 'SERIAL_EXECUTION', 0, 0, 'GLUE_PHP', '<?php
- echo "xxl-job: hello php \n";
- echo "脚本位置:$argv[0] \n";
- echo "任务参数:$argv[1] \n";
- echo "分片序号 = $argv[2] \n";
- echo "分片总数 = $argv[3] \n";
- /**
- * 传入json数据进行HTTP Get请求
- *
- * @param string $url $data_string
- * @return string
- */
- function http_get($url)
- {
- $curl = curl_init(); // 启动一个CURL会话
- curl_setopt($curl, CURLOPT_URL, $url);
- curl_setopt($curl, CURLOPT_HEADER, 0);
- curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
- curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false); // 跳过证书检查
- curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false); // 从证书中检查SSL加密算法是否存在
- $tmpInfo = curl_exec($curl); //返回api的json对象
- //关闭URL请求
- curl_close($curl);
- return $tmpInfo; //返回json对象
- }
- $url=$argv[1];
- $result=http_get($url);
- echo $result;
- echo "Good bye! \n";
- exit(0);
- ?>
- ', 'php_script', '2022-06-07 02:02:08.743', '', 0, 0, 0);
- INSERT INTO "xxl_job_info" ("id", "job_group", "job_desc", "add_time", "update_time", "author", "alarm_email", "schedule_type", "schedule_conf", "misfire_strategy", "executor_route_strategy", "executor_handler", "executor_param", "executor_block_strategy", "executor_timeout", "executor_fail_retry_count", "glue_type", "glue_source", "glue_remark", "glue_updatetime", "child_jobid", "trigger_status", "trigger_last_time", "trigger_next_time") VALUES (3, 1, 'python_script', '2022-06-07 01:49:40.531', '2022-06-07 02:04:03.534', 'zhangsan', '', 'CRON', '0/5 * * * * ?', 'DO_NOTHING', 'FIRST', '', 'https://api.vvhan.com/api/zhihu?username=uxiaohan', 'SERIAL_EXECUTION', 0, 0, 'GLUE_PYTHON', '#!/usr/bin/python
- # -*- coding: UTF-8 -*-
- import time
- import urllib.request
- import urllib.parse
- import sys
- import codecs
- sys.stdout = codecs.getwriter("utf-8")(sys.stdout.detach())
- print("xxl-job: hello python")
- print("脚本位置:", sys.argv[0])
- print("任务参数:", sys.argv[1])
- print("分片序号:", sys.argv[2])
- print("分片总数:", sys.argv[3])
- def gethttp(http_url):
- print(http_url)
- response = urllib.request.urlopen(http_url)
- result=response.read()
- print(result)
- pass
- gethttp(sys.argv[1])
- print ("Good bye!")
- exit(0)
- ', 'python_script', '2022-06-07 02:04:03.534', '', 0, 0, 0);
- INSERT INTO "xxl_job_info" ("id", "job_group", "job_desc", "add_time", "update_time", "author", "alarm_email", "schedule_type", "schedule_conf", "misfire_strategy", "executor_route_strategy", "executor_handler", "executor_param", "executor_block_strategy", "executor_timeout", "executor_fail_retry_count", "glue_type", "glue_source", "glue_remark", "glue_updatetime", "child_jobid", "trigger_status", "trigger_last_time", "trigger_next_time") VALUES (5, 1, 'spring_bean_simple', '2022-06-07 01:53:28.497', '2022-06-07 01:53:28.497', 'zhangsan', '', 'CRON', '0/5 * * * * ?', 'DO_NOTHING', 'FIRST', 'demoJobHandler', 'test', 'SERIAL_EXECUTION', 0, 0, 'BEAN', '', 'GLUE代码初始化', '2022-06-07 01:53:28.497', '', 0, 0, 0);
- INSERT INTO "xxl_job_info" ("id", "job_group", "job_desc", "add_time", "update_time", "author", "alarm_email", "schedule_type", "schedule_conf", "misfire_strategy", "executor_route_strategy", "executor_handler", "executor_param", "executor_block_strategy", "executor_timeout", "executor_fail_retry_count", "glue_type", "glue_source", "glue_remark", "glue_updatetime", "child_jobid", "trigger_status", "trigger_last_time", "trigger_next_time") VALUES (6, 1, 'spring_bean_broadcast', '2022-06-07 01:54:45.836', '2022-06-07 01:54:59.474', 'zhangsan', '', 'FIX_RATE', '5', 'DO_NOTHING', 'SHARDING_BROADCAST', 'shardingJobHandler', '2022-06-01', 'SERIAL_EXECUTION', 0, 0, 'BEAN', '', 'GLUE代码初始化', '2022-06-07 01:54:45.836', '', 0, 0, 0);
- INSERT INTO "xxl_job_info" ("id", "job_group", "job_desc", "add_time", "update_time", "author", "alarm_email", "schedule_type", "schedule_conf", "misfire_strategy", "executor_route_strategy", "executor_handler", "executor_param", "executor_block_strategy", "executor_timeout", "executor_fail_retry_count", "glue_type", "glue_source", "glue_remark", "glue_updatetime", "child_jobid", "trigger_status", "trigger_last_time", "trigger_next_time") VALUES (7, 1, 'shell_script', '2022-06-07 01:50:13.086', '2022-06-07 02:05:11.828', 'zhangsan', '', 'CRON', '0/5 * * * * ?', 'DO_NOTHING', 'FIRST', '', 'https://api.vvhan.com/api/zhihu?username=uxiaohan', 'SERIAL_EXECUTION', 0, 0, 'GLUE_SHELL', '#!/bin/bash
- echo "xxl-job: hello shell"
- echo "脚本位置:$0"
- echo "任务参数:$1"
- echo "分片序号 = $2"
- echo "分片总数 = $3"
- echo "开始HTTP模拟请求"
- url=$1
- result=$(curl ${url} -s)
- echo $result
- echo "Good bye!"
- exit 0
- ', 'shell_script', '2022-06-07 02:05:11.828', '', 0, 0, 0);
- INSERT INTO "xxl_job_info" ("id", "job_group", "job_desc", "add_time", "update_time", "author", "alarm_email", "schedule_type", "schedule_conf", "misfire_strategy", "executor_route_strategy", "executor_handler", "executor_param", "executor_block_strategy", "executor_timeout", "executor_fail_retry_count", "glue_type", "glue_source", "glue_remark", "glue_updatetime", "child_jobid", "trigger_status", "trigger_last_time", "trigger_next_time") VALUES (8, 1, 'node_script', '2022-06-07 01:51:43.617', '2022-06-07 02:06:47.131', 'zhangsan', '', 'CRON', '0/5 * * * * ?', 'DO_NOTHING', 'FIRST', '', 'https://api.vvhan.com/api/zhihu?username=uxiaohan', 'SERIAL_EXECUTION', 0, 0, 'GLUE_NODEJS', '#!/usr/bin/env node
- console.log("xxl-job: hello nodejs")
- var arguments = process.argv
- console.log("脚本位置: " + arguments[1])
- console.log("任务参数: " + arguments[2])
- console.log("分片序号: " + arguments[3])
- console.log("分片总数: " + arguments[4])
- let name="张三";
- console.log(`我是${name}`);
- console.log("Good bye!")
- process.exit(0)
- ', 'node_script', '2022-06-07 02:06:34.115', '', 0, 0, 0);
- INSERT INTO "xxl_job_lock" ("lock_name") VALUES ('schedule_lock');
|