当前位置: 首页 > news >正文

辽宁省建设厅网站升级何时结束瀑布流 wordpress

辽宁省建设厅网站升级何时结束,瀑布流 wordpress,工信部网站备案流程,宜兴埠网站建设原理 触发器监控工作流实例表#xff0c;当工作流实例表中的状态更新后#xff0c;针对状态为失败的任务进行企业微信告警。 发送企业微信消息函数 # 必须在pg的主机上线安装requests模块 pip install requests # 以postgres用户登陆psql客户端到etl数据库 psql etl -U po…原理 触发器监控工作流实例表当工作流实例表中的状态更新后针对状态为失败的任务进行企业微信告警。 发送企业微信消息函数 # 必须在pg的主机上线安装requests模块 pip install requests # 以postgres用户登陆psql客户端到etl数据库 psql etl -U postgres # 创建插件plpython3u create extension plpython3u; # plpython3u为不受信语言所以只能被超级用户使用 # 在tool模式下建立发送企业微信消息函数tool.sp_send_wechat CREATE OR REPLACE FUNCTION tool.sp_send_wechat(message json, webhook character varying DEFAULT https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key你自己的key::character varying)RETURNS textLANGUAGE plpython3uSECURITY DEFINER AS $function$ import requests import json/** 作者 : v-yuzhenc* 功能 : 给企业微信发送一条消息* message : 需要发送的消息json格式* webhook : 企业微信机器人的webhook* */import requests import json# 企业微信自定义机器人的webhook地址 p_webhook webhook # 要发送的消息内容 p_message json.loads(message) # 发送POST请求 response requests.post(p_webhook, datajson.dumps(p_message), headers{Content-Type: application/json})# 打印响应结果 return response.text $function$ ; --将函数直接转给tool ALTER FUNCTION tool.sp_send_wechat(json, varchar) OWNER TO tool; --公开函数的执行权限 GRANT ALL ON FUNCTION tool.sp_send_wechat(json, varchar) TO public; --将函数的执行权限授权给tool用户 GRANT ALL ON FUNCTION tool.sp_send_wechat(json, varchar) TO tool; \q企业微信告警触发器 由于企业微信markdown格式的消息艾特指定的人只能通过企业微信中的userid(即用户在企业微信中的账号)调用所以我们在海豚调度的元数据表t_ds_user中增加wechat_userid字段人工将海豚的用户对应的企业微信的userid维护上去 # 以dp用户登录etl数据库 psql etl -U dp # 增加字段 alter table t_ds_user add wechat_userid varchar(100); comment on column t_ds_user.wechat_userid is 对应的企业微信的userid; # 维护wechat_userid中的数据 # 这里根据自己的企业实际情况做 update t_ds_user set wechat_userid YuZhenChao where user_name yuzhenchao ; # 创建触发器函数dp.tg_ds_udef_alert_wechat CREATE OR REPLACE FUNCTION dp.tg_ds_udef_alert_wechat()RETURNS triggerLANGUAGE plpgsql AS $function$ /** 作者v-yuzhenc* 功能海豚调度工作流失败自动告警* */ declarei record;v_mobile varchar;v_content text;v_message varchar; beginif new.state in (4,5,6) then for i in (select||d.wechat_userid||\r\n# [DolphinScheduler Job ]\r\n 实例 id : [||a.id::varchar||/||b.id||](https://dolphin.tclpv.com/dolphinscheduler/ui/projects/||g.code||/workflow/instances/||a.id||?code||a.process_definition_code||)\r\n 项目名称 : font color\comment\||g.name||(||g.code||)/font||\r\n 工作流名 : font color\comment\||e.name||(||a.process_definition_code||)/font||\r\n 任务名称 : font color\comment\||b.name||(||b.task_code||)/font||\r\n 任务类型 : font color\comment\||b.task_type||/font\r\n 开始时间 : font color\comment\||to_char(b.start_time,yyyy-mm-dd hh24:mi:ss)||/font\r\n 结束时间 : font color\comment\||to_char(b.end_time,yyyy-mm-dd hh24:mi:ss)||/font\r\n 任务状态 : font color\warning\执行失败/font||\r\n 所属用户 : font color\comment\||d.user_name||(||c.user_id||)/font as wechat_content,d.phonefrom t_ds_process_instance a inner join t_ds_task_instance b on (a.id b.process_instance_id)inner join t_ds_task_definition c on (b.task_code c.code and b.task_definition_version c.version)inner join t_ds_user d on (c.user_id d.id)inner join t_ds_process_definition e on (a.process_definition_code e.code and a.process_definition_version e.version)inner join t_ds_project g on (e.project_code g.code)where c.task_type SUB_PROCESSand a.state 6and b.state 6and a.id new.id) loop v_mobile : i.phone;v_content : i.wechat_content;v_message : $v_message${msgtype:markdown,markdown: {content:$v_message$||v_content||$v_message$} }$v_message$;--告警perform tool.sp_send_wechat(v_message::json);end loop;end if;return new; end; $function$ ; --授权给dp ALTER FUNCTION dp.tg_ds_udef_alert_wechat() OWNER TO dp; GRANT ALL ON FUNCTION dp.tg_ds_udef_alert_wechat() TO dp; # 创建时候触发器 create trigger tg_state_ds_process_instance after update on dp.t_ds_process_instance for each row execute function dp.tg_ds_udef_alert_wechat(); \q测试 新建一个工作流选择SQL组件 保存工作流 上线工作流并运行工作流 工作流运行失败 随即企业微信来了消息提醒
http://wiki.neutronadmin.com/news/447011/

相关文章:

  • 网站建设的科目印度电商平台网站建设策划
  • 网站 推送cms下载官方网站
  • wordpress快应用关键字优化策略
  • 网站建设招标合同要求深圳建设银行分行网站
  • 电动车网站建设哈尔滨百度宣传推广
  • 石家庄做网站比较好的公司有哪些上海企业公示信息填报
  • 国企怎么做网站sem是什么公司
  • 天津市住房和城乡建设网站网站开发公司更换
  • 北京pc端网站开发成都网站建设技巧
  • 凡科做的网站推效果如何做好网站seo优化
  • 拼团网站开发免费高清视频会议软件
  • 武义做网站厦门百度推广排名优化
  • 网站内容规划要包括什么内容上海优化网站排名
  • 如何注册个人网站新手做网站起步教程
  • 长沙网站制作公司推荐做画册可以参考哪些网站
  • 企业网站托管电话wordpress非插件oss
  • vs2013做网站复兴网站制作
  • 岳阳做网站四川省建设厅注册管理中心网站
  • 站长工具seo优化系统公众号转wordpress
  • 推广方法有哪些技巧重庆企业seo网络推广外包
  • 贵州网站备案局营销策划公司 品牌策划公司
  • 上海制作企业网站wordpress托管服务
  • 公司网站打不开是什么原因正规网站建设商家
  • 淘宝做任务网站基于php+mysql的网站开发
  • 腾讯静态网站托管铜川网站建设
  • 政务网站集约化建设南京快速建站公司
  • 类似红盟的网站怎么做电商详情页设计公司
  • 微信公众平台微网站怎么做做网站建设公司排名
  • 建设网站的硬件北京网站搭建服务商
  • 做配电箱的专门网站做行业网站投入