From d144f48ed7be609af4332d16a7d4768019c29fe4 Mon Sep 17 00:00:00 2001 From: xujiaqiang <54771125+xujiaqiang@users.noreply.github.com> Date: Wed, 13 Dec 2023 15:56:37 +0800 Subject: [PATCH] [Feature-15248][dolphinscheduler-alert-plugins] add alert plugin aliyun-voice (#15248) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * add alert aliyun-voice * VoiceParam replace these with lombok @Data * security.ts add alarm_instance params * optimize alert aliyun vocie code * Merge Code * rollback pnpm-lock.yaml to branch :origin/dev version * add the doc about the new plugin * add com.aliyun.dyvmsapi20170525 version 2.14 * completed * run mvn spotless:apply * Code optimization * Change to @Data * Code specification optimization * add com.aliyund.yvmsapi20170525.jar license * modify com.aliyund.yvmsapi20170525.jar license * modify com.aliyund.yvmsapi20170525.jar license * add aliyun-vocie licenses * add aliyun-voice link to docsdev.js * modify vocie module to aliyunVoice * add lisense --------- Co-authored-by: xujiaqiang <“xujiaqiangwz@163.com”> Co-authored-by: 旺阳 Co-authored-by: David Zollo --- docs/configs/docsdev.js | 7 + docs/docs/en/guide/alert/aliyun-voice.md | 32 +++ docs/docs/zh/guide/alert/aliyun-voice.md | 32 +++ docs/img/alert/aliyun-vocie-form-example.png | Bin 0 -> 24249 bytes .../pom.xml | 40 ++++ .../plugin/alert/voice/VoiceAlertChannel.java | 70 ++++++ .../alert/voice/VoiceAlertChannelFactory.java | 95 ++++++++ .../alert/voice/VoiceAlertConstants.java | 79 +++++++ .../plugin/alert/voice/VoiceParam.java | 74 +++++++ .../plugin/alert/voice/VoiceSender.java | 101 +++++++++ .../java/VoiceAlertChannelFactoryTest.java | 47 ++++ .../src/test/java/VoiceSenderTest.java | 52 +++++ .../dolphinscheduler-alert-all/pom.xml | 6 +- .../alert/api/AlertInputTips.java | 7 + .../dolphinscheduler-alert-plugins/pom.xml | 1 + dolphinscheduler-bom/pom.xml | 7 +- dolphinscheduler-dist/release-docs/LICENSE | 17 +- .../licenses/LICENSE-dyvmsapi20170525.txt | 202 ++++++++++++++++++ .../src/locales/en_US/security.ts | 6 + .../src/locales/zh_CN/security.ts | 6 + tools/dependencies/known-dependencies.txt | 16 +- 21 files changed, 893 insertions(+), 4 deletions(-) create mode 100644 docs/docs/en/guide/alert/aliyun-voice.md create mode 100644 docs/docs/zh/guide/alert/aliyun-voice.md create mode 100644 docs/img/alert/aliyun-vocie-form-example.png create mode 100644 dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/pom.xml create mode 100644 dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/main/java/org/apache/dolphinscheduler/plugin/alert/voice/VoiceAlertChannel.java create mode 100644 dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/main/java/org/apache/dolphinscheduler/plugin/alert/voice/VoiceAlertChannelFactory.java create mode 100644 dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/main/java/org/apache/dolphinscheduler/plugin/alert/voice/VoiceAlertConstants.java create mode 100644 dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/main/java/org/apache/dolphinscheduler/plugin/alert/voice/VoiceParam.java create mode 100644 dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/main/java/org/apache/dolphinscheduler/plugin/alert/voice/VoiceSender.java create mode 100644 dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/test/java/VoiceAlertChannelFactoryTest.java create mode 100644 dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/test/java/VoiceSenderTest.java create mode 100644 dolphinscheduler-dist/release-docs/licenses/LICENSE-dyvmsapi20170525.txt diff --git a/docs/configs/docsdev.js b/docs/configs/docsdev.js index d94250e9af..bc08fc9c79 100644 --- a/docs/configs/docsdev.js +++ b/docs/configs/docsdev.js @@ -407,6 +407,9 @@ export default { { title: 'Slack', link: '/en-us/docs/dev/user_doc/guide/alert/slack.html', + },{ + title: 'Aliyun Voice', + link: '/en-us/docs/dev/user_doc/guide/alert/aliyun-voice.html', }, ], }, @@ -1121,6 +1124,10 @@ export default { title: 'Slack告警', link: '/zh-cn/docs/dev/user_doc/guide/alert/slack.html', }, + { + title: '阿里云语音告警', + link: '/zh-cn/docs/dev/user_doc/guide/alert/aliyun-voice.html', + }, ], }, { diff --git a/docs/docs/en/guide/alert/aliyun-voice.md b/docs/docs/en/guide/alert/aliyun-voice.md new file mode 100644 index 0000000000..332b6fddae --- /dev/null +++ b/docs/docs/en/guide/alert/aliyun-voice.md @@ -0,0 +1,32 @@ +# Alibaba Cloud - Voice alarm + +If you need to use `Voice` for alerting, create an alert instance in the alert instance management and select the `Voice` plugin. + +## 参数配置 + +* Called number + + > Called display number + +* Call display number + + > The number for receiving voice notifications + +* VoiceCode + + > Voice ID of the VoiceCode + +* accessKeyId + + > Your AccessKey ID + +* accessKeySecret + + > Your AccessKey Secret + +### example + +Voice notification Sends a voice notification of the file type to a specified number。 +The following shows the `voice` configuration example: + +![enterprise-wechat-app-msg-config](../../../../img/alert/aliyun-vocie-form-example.png) diff --git a/docs/docs/zh/guide/alert/aliyun-voice.md b/docs/docs/zh/guide/alert/aliyun-voice.md new file mode 100644 index 0000000000..f9dcce349b --- /dev/null +++ b/docs/docs/zh/guide/alert/aliyun-voice.md @@ -0,0 +1,32 @@ +# 阿里云-语音告警 + +如果您需要使用到`语音`（阿里云）进行告警，请在告警实例管理里创建告警实例，选择`语音`插件。 + +## 参数配置 + +* 被叫电话号码 + + > 被叫显示号 + +* 呼叫显示号码 + + > 接收语音通知的号码 + +* 语音模板 + + > 语音通知文件的语音ID + +* accessKeyId + + > 您的 AccessKey ID + +* accessKeySecret + + > 您的 AccessKey Secret + +### 阿里云-语音告警示例 + +向指定号码发送语音通知文件类型的语音通知。 +下图是告警配置的示例: + +![enterprise-wechat-app-msg-config](../../../../img/alert/aliyun-vocie-form-example.png) diff --git a/docs/img/alert/aliyun-vocie-form-example.png b/docs/img/alert/aliyun-vocie-form-example.png new file mode 100644 index 0000000000000000000000000000000000000000..626e7242433458df5b1cc8065a66f9980d831562 GIT binary patch literal 24249 zcmdSB30#u--Z$)YPScs3rp={tn|9O8v2so2Or=hlI$CB5%7mGjpdqQb(kxA>DPwM# z3nxu2O$bd86=*}s1*S|PK`b{?LsA431fD-O&6#tabHDd}?)Uz@&-42ERF`yd{rBJU z{eFK}#<#v+E0%9quBWHB;?Oq-1N8KkkinmszkCWlvF#`-1pj=33GmvlM_`+dgJ1p} z`L)m2dU_sCPqXSZ%Jy!c9LMl(~eM-9iHn)FRk=*ok@v}Vvm;dUS z@!-qRrHLHZs533=zjFH(wddElsvr3g2i{aXNH|H^XDxDZ4?=T8xh)D|jr^6UG~V4} zyv`-1K4oAsEV_uJ=_7=)7_#?|jjQ>Xu!G=d0TE>vta)$774Tyk-)BP&j0)Xuoh6=^8hhv-@bjJI5m?`j=0J34!C*^* zxarX1V=bjGydika98N3FE#wd0(9?T;g(mBR90?+7hQ8^nN9gN4@I6S)PK;^f5st>x zE!k(xG}60RmVw(^x-ap~Hyw+2uuqXtohTzdH4a+9v&yv5)7!U}DbMv{ON{yQnjOgD zQ0U^fqOwrX7|Jx^!?pW&8qht~=xfqaz3*24S1(a*apL~jTwGczWIDbXJ={J!-YO{;Dl{v7Ij+)o z8uIY_DqDyE-&?u|6@ruw^gS+jQQY+IbW_nJ+2K@G2S*SvS6StA$PMK-T6pw)cIYHS-Qg`@n|BGR5aiioPf(t4& zyo8*1eQ1{<#?$$Wy2CTKd1EA$GD-QOoHcSIJk>QvoYd_cM6erasY|QtGUUqz8@Wd7 z3tl9^Qc~Y40>k&)6BvnV$@e}}Ux#7#VP&Rrh3oDc#(K>I#XHHEDiH;e%uPS}%7fHx zKXOAA$1SlYW4LRgBwkRYmdRMKh{<_oFPhiB7ph{cPvkoJ!Qb|$O`fRX9q0B4Ro@mo zI1(lmq(yOE9Jjp?w#pR`xaAiR;*?*wy)}$-s%pcy#8B_6*lF#BySAS?Cmh>#+>oEo zylwOKx2tFRdB6G_{cL{Fyx8AjhqPpc|3_&Qw5KL?!DZ8tl>Jn@3x23+N zW>VN%x}D22Z)8hq62u!j&^ag(q0gMJ5}E4VF1v%+7qls$FgIR5(x8w^^+cqaa*Yey za%!JmmCG7dk-5(cpPZ#ptL4}8xvzws_a@TiaVylWl^79SeqGRK+%9}eEy;^Ua$kf+ zVzr{FuZ4|)oS-mo`(0QFp~YA4H7atV@-G;sRrcX-a;EqUedq38<;(_AW&pvh{Z#+t zZ9=`hRaPY?Hf|+&t}L4!I*`|P8Qmp7pFB^5)=dr6CMi>X85T{&TjR{CXbF1X35%`B zl|$E~osaK^zm_W=(lR{eECa1r>G$Dw}OZg@Gt@p%R0fseOi>@ngjh776it4rM zA~3>WYg|3SOpn(E2DmZn1U#St=Fw+k@64^8xi({pnxAN@x=kx@YnQ{4G-QJayDYId z{?v3dr6~>-_^_5;7Pn$jpn@I1sw*);tS58nHqKuAVy41=_L&N0H^z`wP|Lqz^vP>B zjmTutpOGYqSjox`%o05c^cbnk8@jW9)APsye0YgcO0KHC7Ex>KLMx@%xKQie$Tohc zA<@fr`}^En?m$fRC@hV-yq9`3>?qvSn)f;o&*)nTH9LW+hx6+#8-bMyTxX>qx4N zb55N4g*#Z(a+q+F;a7>_nDrF3Qzs|zlX6qAn*$lkW;DkXU*Z)SSDI@q7~>7Si~XB) zwpVA6cmANWxSRfOxI9RrDTJyT)l|y47Om!T^)mAd7n0vU^s2sW?n1#|ws0RDd4x(D z$<1o~V8t!TE8XYbhaGaG1bK4&MC{P(Y&^p$wE0{V1o#1Zv3HR<&8El};_$&IEn4|M z>)eyax5$$Zg~_8$sVurpQ{|N(vDy@ZQA5@;{q*%Tb8;alUo_OcyH>I z$kAKut(9qa(=?BZzL4uZc%H#6xiCNtj!}f+622x~s!ATNFTn=nK%A|c^xg%uO+A_P zqZ^6A^ybxn~F#f+cp!tk+7{?feCy{{X!& z2az%*ppHMfq~F8LGOqD1+T~MZ3okcMn|-c!mGiYa&qbv244dFCF>i~($~#9 z$PbQ#MKpC}8u2o#jG+-`uSbp|zpwxHkL~!7LT|@nMbE~~B&l2tar?799M^p`iQ1x+ zK0C@nCfp ziCaC6U+9TazJ}bW_Di1-KjD&W_#D^r{tj)w znrR&*AEagnaO*NrMngRFjBq}qx;t*JX?r~P`aTZzwGVv|K4Cc=SgTmnnkB7r}R_ZV`C zJ0h&qnBQkr%NKIxitZK=$UxrTTKjNzf{ zsksu-XTdSREX3lTaMM0Jo7G>Me#Cu>yCFK7yLy=a$e3SwvF1d0E9A*_p3rQCv%TNACxqw{g)nto;Y0n;8~>)9?BFzCA7 zH?}%tMHh0&PshkRndnqV5M-OHY<8twv{Ky`{6nL_imbOCk4Py^pL-mo9Psn$>8*?1 zPR~L8$={*B;@Z+`+q}vAJo--0hfyNmUU@0QCMNh^e?VX7Zmuyup?sA}S~}UqFKTpF zt2@DJ!1oQ-N=2A&Lm!{s+Qhcz%eKP*ZeQa89=y)fDDNy>h)eyc<0=_@Gz zuPV>TBN`3)aWL2cDAJ2{iK-S;4WSqF{77yQ70B63o6Qwfbyhp;owms-ORdO(9(Vi8 ztM1|%A>P)w&W2uyuU#yITzj#a+C*u1+oXt?a%b{NZ988JsG_keEV2D;A5DIou$5h; za9#rsVk}c8#UTa6uM!83yWt8@2K>}SGFD`7p^(&)5zxXRR}gM#39+#;!UW&n&Q31* z<*}%&z|?`5&NaO`+53Bq@cz%nDWX)d^W)n6`K*ZINsF3vwH>^xWD+O6Uu!Q{ShJsV z_z+()t+=%>AJY{v)f`WBlZ#+zxA|8SZJeZ7rOKQovcF|oqOeWxrmBuHj6K0(g{S#@ zO3QjI^R>)SMx!?ROx9_lO^vgk5&t=QBd*N*T@dmUUw5Y5AmfLl1=;kwKaovGHT1dr zqc+DzzdFVjb%b3Nb9yE^1udh5f{43reogIXp%956sXt{8rQLuv#`C$05%*r#%)hg! zIUDNiFy(VXmWo1{FdYtNbTKrz#Iud1WAvRjXgmi+j`(f!ujc!_blcv5f3(7O3ypl` z64}&)l=TDG!UV?;ADWJ`ByVh|L{D(9E9&6hrj#gBS&8+iT1-4y5Ko|mz{_p9dnk0L zZN!bEyk_{#4VV*rEAo62H+JEbqarH`>gk0q$VLU9+KeKZnHk4n(?@Pr@RpROW{P*@ zZoO^eR8QX`yL8(&J@|cpz)?fqwG_f3c(Ex6@--iax4*C&}3l77I&!$C>1y)M>b3Rm!z+)x1*V zD5r26a!`i+RZI7}|L{Hq`yQw8jo8rM4v$CJGqhOP^YGg9mtrkX^JgnuGp|hM!6G#@v|wPU_)sVy_K+B$ic|Q z+icq78>&5O)?bEhC=n*gVdZ?I;JE6;Nm)uplrZI60v30N5pOxu=;ClSZwd4!Z^=1< z0rWfT57u2D$$XJzqdV>T$V)m;^)LL(Qu6+P_C_Bc$DeM8Ix>o3^G_^%h}!p6Kbq;C zn;nYZ9){I5Ap|Z~HF$)esf+csRdcmjarzH@pG^Ab{3s`#G?3!fzm#cY^sYWAtaX0- z=-k*EY+Me*2;|ew9Zx2^y8~K_E_}FUs=g>aNotaH<;qjSTH=A$3f`mj_q1&BL)IFQ zJ11PDamzw!M@#;ziQT`G1pYVgy|ib@m@(Hon}=_6b<-|n{XGN$Zt%_LS7LYB(&rk- zo4CU3!c?iv>eacMecFUiCfNjCrXTs&g=fKc3|HrdZVO8sl0_C7K%M?HM7&fR>!N#5 z@dfp(Doe6Ln4&#Dn6}baF{u4@_Q9W4`hno-Y1k{be~zr){PZo-oGDW-pkj3H zsXEKp*0*R^=#5=)x~rS=Oq+@7?JO@GH_#OcQN7~NP&sKa4w*Kkt1{~Wis1#8bJ73` z7A6M-I(<9Hn>NLn`h!s9=;Cw10fpA^GOs*EA0#a$`;tJ%hp&JgHLxpFtW{&RrsUp zu-1foqa#UU#gR1%n)b(@BKpGI!$Psk#5|O5Ne(`yeaF!tm9IDiAz8b{kRQ*cMfnGU zUOC_pozruVjBCa<%f2wb8nH2jwQsNqKj%V54OwQQKvo=6XK6*IY|9GW(ivSs=b0xW z%t+-Yf||6?w&P1}#y4$hD6=G+;w;Izh7~_~6szTl<*vM$gqv3@l84)~f3&GH^B@f* z_zNPYUC)B9`2V@m(sTV?;b(49%!K>pmW^mLw2#_-_3Bq)2G9i2zYdV%E1J`lQz>%q z@v;D9;-qgD%IKkG#xxrx^F0IKqQd>Di*}%2W2hCh-bEv!)ffWITjm>Aj-4u1Cn4CS z+g}tZ63VFc1Lflig;WlvFUOkLHj_2pQBc&8hDz5+qkFtnGR^hhW37BYq4`_N#ca_A(LDt|Yw&buzjtu^%V3|3f?YPRQQXp`#FSVzO{Y!0io{zhh?$7aDQ0B! zW^4CIz7fa&`36JsPD&c7zWvFxonM!6+z~9yp#4{TqHj*tE7^SYk$N;vnV;1H?%n(!)>Qd&Kzez`Z4 zrc4-`e@5^iQRmmtBeR6WOO#tKO# zo}|%ZSFRauwRusiCEV}iR&yMEy;yQnzg62A--ijtIhydD%hL7H3I&=i(-`iP-s(9VB^?VtkgkLc` zDhM{%?B$P?x}uN3?}~Dw6ioDVGx)*}{lwsdBez5~khE4oyMkJwcEyCE2^7a+zs68OXC8k-{GRO(yl`zkvMeS7~~K$p|>>$^$c(gOqEf}T&x<kkQ^&@{d6dus{HsYi{y30bCGT8m7&mwQM-X?xJ+B8qpX(vY8ZNpma zpMnSKHGWHu*gKYip5+-he% z0uLT6T+cMh;lWP2olO#w^&}mKK#Ulq6;cgW2d4vHh+qXGhf~$9k6PodW!5J~dmLo@ z>OS@gMOHSqvp(xzQeu(Ii!b)wev>x_SuzPRvEH<)6C~DNNMi|a%z0)HId^#OFZ*2% zNpx=ORR(ZYWe9K&YcDCr>kmCbDcRavtz5=)n zy5++3i*$hBr|to;O)?Z99;8=`tijd)21xZ_cBS_HO4XZFQdct~cCMGG_){qiOyt-8 zIbmrs+4w{+{D^Ja`XhEW~JGE>f{WzP2saSKko1{nk|_%d#x5q2A*J**spt;s*+k75 zWv@kAbn@_^_EhpDb5fN-42QnUva^%lF1?hpf`5w_H{mMnYV1)7wGYR=;pq$C=}#(q ziD84*2W%xp6@kKCzP1vJ$1&oGq|63`s;GheC52(+Fs&n`G+miN(HGBZ7a+@^`Y9^8 z{*;jCG-hc@zPFw!-$_l5zmcvu+B5rjKK6lQjNrOE0Cal1+~w2b1wY2#s+XoPc2pem zq#{SrxpPWOaSN~Ao&l(h8{NAINhU*~G={1bKV|qg?ib{{M&ZNjB!VgSE__WYMeghU z;#$Y?HdV4rp^?ohwezzN3wserQ;dNGKnaVDXCPF5nsGkki-RZcc0?NtSho3((bZ+! zSCZ-CyKPxFxUb;aL&o^Wsq>?FiFz4BY4#w@bS+D{Q}moKliuP9t=w%>#99@DruIdN zg0#bwYP=e(-s}tP3{?&AA8UXGQPjnN{Bfw{l`qB0yFWltt?44i3>Jy@RZu`>mj@|3 z(Q-Jn>-f96<&qbreF&8tj$)jDe+Gkow+-8CCi!kKjT0${Uj(5Gy-qzBL~nstR~%~^ zTH0o23{dYtRpXye4Vl(2)XkmM)>3hg!1$Z{+Q>%=tK=9;uBJbzpgtZyTq??dX!6v< zbY};ydGhcaplA7Cywg9=zCcsU&ZqNU<7yxM0u%4sVrbmGHH*lY`BpbL4O2%+@qPI`VHy zCy(-0GbzB#n#HCVz}mrsSfYIbQguSMns$fH4`T_g`#fR%4bs(maYs%zwwRIA%$gn& z80B7=PM;XJc!#CMj6XA8pe7v`OZ5L*$TP*`!rj1~&c{O^`@b5M8qAoJx9*toh9$bM zRHx}r%Wfl40RTy&Oi=e(P3L`~OpG2bdsX}Lbbn&ZFc?=TznS}>-hkh@$vwzK^3wB8 z=(IEcSL5Efc9TnAEkB-re^B!_RK*~xhOVy)@81NVgSf)saH#p(F*1wmzg(J%I)t>K zh@J+lmyTw6Hr2Z%Y++Ht`AhhjcGM}ktC%)Uw0T073t6s{gjjZ#tp+K%u~Hj!3ytg| z5t&Yg~SHGkWA%z(JFF?d9Ya1Lr4^0;e5 zpKrE_JsFe29t7c(z_^n)SlF&XXNnU8kO$zN2aug>+$ilD;jF@KHvEgt>GG(B>$e{- zqW`Dt?qvF$sF@uxwIes2)e5q(u566g&?I^9tw8R%V+r%Fm)e$9UNhi$3p(Xtcdek4 zuB`cHhE@&RVQwLlPS0TFwsLG~P@Pp{T7anu#IqtW?=w4Y?!+*C5SqmxpNniA+=QD|`Q!Y5SLolveoaMLOeGXqoe(o+b|7Myy!Cuv>rOm5oOUx=?i zb|O47uzjG;dhb%T9fwbu4r_wI7ev=sO~Xq2Y{Hw{r9UB{p^4hkdMjNjhKb^~paMw) zBW8S`EV09fUIeGT$-HHGCisE!g`uj#(i72@6-0O^;n?NM(Kq8(y?b8*ewoj&iFmu>JPC63XtGV!; z$hO-qs#|^_eudX)GbD4B!oB=Qa_Y|-=Y121)@K-sPp{W%hxx1GZ5AH9KH8@-RlMES zos&A=R2vN)tGLbdTDu6G?sv2*p7v?AxvL)DOGztXlJWcQ4)Hei#tMps=%ex$s^Yf+`5vJ^GrHwZ(0xv z@tZb%g2~;wL-IAYZ2Cf8LlYZgs!V!xvb+^_M>Bom#AMB;cdte)aHz?!KT!gZ#RU;N zJC18(PPTpJ@rmkjilnvbZQxeBtSBS0E7|rOhEMTF9*8&FNRF-KjnU_J=%dRMj-=Q^ zlTcK-)3$cz9IAg5mz!xkGB@pW$JPq$NhgwR*j+wqeu>;J zRJ4g=LvsP5^X`S|jBD$wh_)pg^-n^LRBJ-IbNNbV5jnPwH`bh>G407QdFDLU-o61c ze`k;(-Z0ZFcTJ*+)pg`c*AvTR-LGUTH5}u&M_gkfZk|=J^e;e@_k;98t#(l&3~+ok zD)AB$(XWkwI)N7hSC71I01-4eY{&O*+d*qZZd7W?bH`jiz5KO;K7 z&1YJMr$v1pyu9&TwV*r$f5;@lrZenTTIrasTR)S(^KAG^K0J2UitHT3D0JPG9uo_L zmosedZIm3y$++7{4qUK}_glv4nRbcNdWU|uC(|Y}EWh2d%->z|QUD7^)>7YEXf_5QntEn1tFI%JNKHMNkj>nS1yKtWak zPb%x>Dzr=0`nGLt+D1R%(H1%vc$8<6_Rbs1YlaQ+MYL%dy#CLe;(BL;koi0xy%3wC{1SesL5%lW95 z)cKj&x0TZ|?<#x3ac&8F@alJwv7I7!1@*rbxJEvaO%i<{oeHDI#U~GEJFX;uBp_eKQv-Dv;U8#6&SEO@1g`(d1A@W zrprLu(vlZ~988|H3Er$%Q?QuOq_q6$TnJzh`v7I98n%EmCTP?OI^!gr;;&H>@%@&5 z+Sd?dz6J97B$qh&`Gcq`UfkJK)jmI8$pulX99wTbm=Rf?l#o2Af;gp(cj7FN&St(7 zEq?n+>Q1bd1`R0S`cKTb91i_Xq`RyImw{m*L;rs3x5!t5XrfOKWWJ_nHgeFFcduM( zY%4Z?-c=)^N45Yl%|l^tPAhNhIu+C2^u!*O9GZy8U^+|<3@B1hCxh78961lr0fLW? za_eawlnT{=Qmn7w#TYS-PAp*-c6*T2k=lX1>i3tInY1^g$}ZWGwQp#O`p_kQ0i^nl zXxHP&!319HPUBsn^xzN`!bGuG9+{iX^1oOY$1e(DCd30&^D_fzpRtD=qT&p)w?piG z64mUzY40t3fVaQ!)$0WQ&amxOy!4r)30{FsL(L4sI2-p{nF!^HYEUW101J&`n{OvDG@|L>PWc7plx<8fFP^l0i~3Cxps~m zKICe5dH`V(J~XHMoDOibfi|{l(7q`h##S=fF|Sg+Ado_jZeblf9-0W*CQ>d4r5mC% z04L^v-adF@>OQZ%wPms8@x_)sLCd;W-(8atl{|zCN@oM#vDtsB;(SDI{o#}O_sCae zxC33!jfT>Xu=zPrS;J@QQ5jv~{Xi5kWl`hmz$q9WS|DkDCET(3RV^F2p==6bru5RH zL>;KhO<9N%$&9wEkkxe$wbu9kv(1EhN!PWw^>;WTRg_k?$c z^tz*WBzq9z+q#o1jt^37y%z3}L_ZEBQ7hD})du{*TUKCtBFHNr9ID~Pof=yXt+F{8 z6__iwV42pj1IxCXl6gPFycQl4<;fxfwutEZG6?MG6(fIt@C+wxKZv`No znM-JWa0++S+Xz0Mlh zP=^wuH|C%uhn|wsNTKl-wWymk$I40mOMe6Y1%c+zKQ&iRV1HdTObAsmQ5n-EBO(Yk zqVkx?wCYB9K73(F>3L^t-6)r#k%fHX^bA0*oAe_L?j3=S3~?_AraJNCH<;GmLxSO7 zIX#k<>JY@jQ9n0Y!^?WBbdsB>b8fp{oB6Qyd5+?@9Pin^)p zL$>6NnJ5kZ*{1o`KZONu8CE(T3eQji-d|_5gqWIzNsn|ERM^%3)Xn z4DQyV0O*xH(};a>ZY*xJqjx;pQRoU9_u3v7I}{(u9X+n|+M1EOFPGf&o^Dx7gtXoQ zWaKKW&7bvJ$&*|Q@Krq>*{WOG8bG$1exT0ua(-NN$$(=07RmYB9~3)piX+R*7Dc6S z<;<`OCwW31>mR#O`0kc)`-caW?-wazjv4g)(RKRnCuPgpTlkY_aLyT*Y`8Clt;fT9 zsyVE(69`gvN}|FIUtFF#)4B|L)>uwI03qajc4bWn2o1%NX|Dlnd zuQd=5JX_OaT*K2`RtPBx#V%8blJJVZQ8YRsr(AIfMTmmN`Jg4WGaGP*e2SUe#5=z? zks+d~fU3>^G^Pti%5G48zcTFtR(H8c^}N-c1lg7z2>53RQ=ZQ|{k`)P!bJ6f)B8O0 z$)TM{s!k`Qh)ucdY)NL2#vKcH7WM@4y*`e;)w$)(iJB^V5-kB?SLhen*s$=lX5cq zzDPoJ99aM&CID5yanY_ivtFVm`XnJ3Nq}tl$<_ zzQjGVKQ-Q&6b>z~v-z&F>GUTh*1v4z9;?4eD?BTv+K4#AwUg1J4s;SdEQN5^Cdn@j zs&$f0K0}M$p4pLX*y}}KsHHD}99@Yhmp8BCBiPsXT^+m8x@;2A`A%Pe8TjSW@V$u5 zInWx@2)mAeUSkdq&%BM_JSr!j3Pen;a}278^Xc6%6Ec<=e!_m&m|BbzHsR&;`%EHt zutpQ2k{%PSNW!Xyl^B*r6DH?$3(`8AF)4&58drUtO8w%%huE^_uSPkwdW37Ew{7gx zo)udo)$>E>t69_j>9uQk9Q$kG!!YOA8znWNkKe+mw#1F?Bgu`wrinAQ%PCFa$~FD9 zY_9NfsiWwvMa|9{XO5s*9&$8C+<7K`CE^I%S&`Zl?ukJi{;jPC+b(VPK3e$7Y1{Gu z=rI*by+Fn8A~9?Z)<4d#bloP3p~$57qd9g-N9rJSGZVOWN}_(Kp=C~9Id#&szBS~i zP?C_-W~&~)--#%RaG=NFA3Hdo-pj4lDII=9q%7|;#2<#94uF1I$4a|-XL%se#m@=p z+|fX(z1I|NQD&_ewI6f4N+Q{C*1}nGVilMOYU%dAT*!6GXEkuOawIAJI40rH^-j{z&bzJ^43#(Hm=#C0-qKlbV zyGg9M>ynF=#=mnfpXh9VC^asSy7as4iwW6pI*ZLiCEg3qoHZfefLagBwM56(T}}U9 z-N3(+jBLyl10^hEAaU@=9<>6p*X{j-$2~u;bZ-bs;QVVc1^C74e^LK%!BPHvoWwG3 zEe3+oM#?A#)IfY7U_Ae=;)Z|K$$xK{K;oi{Ka9gJBqeL+b+s)ydl%WQ)@q$c9E1^I zR2SNGd&x4W-s`uEx}SF~fDkzM=@WcuL5N<$j(^a$6pqwWgd0A+n0Jy(gaA(GlgN6W zr=C-~ZVe+zys6!-$Lmk-(qkQ3l$f}+e&Xc27$b>at$2X`5IS*U^m6h*`1ACiG_a=G zRfc?twijOCMbQjU96Jumc0WEN zDF7l`WP%*=(aTa;2-wwF95EA#|6`5;Vo6;zed5gBo_;GH7~u ziHDtNA`6Ms0wj=snCh0nBpY%s=p6elSWD`?DkD`mEZz?R&wm|>Pnr6z^S)NbSkS8L ze)I}Qr{*{Qi>4OSsMQyTLBz7W)soz5RqAa^o{yPy5Zd4ULt>%J1Afbe0!$XC`R-Ri z$U2<$sgqY98A{s5c{F!j_|S%01Rw4lIOK?iF&%`( z*@@AHfRS+m!mJY~dlHe2FFk{g*iGH3DR;kczRm|yV|F9z2w~I3pDDB;wt;jSwXX)Ji4wu zkePZEkiG4YyDWe zY_iOR%Z^{i3Pv8i`V4>e-dXx$67avzmLZR-_bwBmZ;cE=9*Dsu9;i$7g#z}+^HQVD z9n3IDXrtfl3Hlosy(SaY@k8sgR#1EutIH?;A0A~|&8xQj*?(1~B|AH#!4T*m62IZk z^hbBT6ExTI2pFMH*)4?0kVRg-ippQGJn)}94rIE!&u%uUsAW!>pz&c2OsC{7!oK6s_fgb!0mrwJ`m<2 znyuQyOa;E_=`{hvgwHroB0^F|oKYCEiXA)kFci^VYfuEQzCi@^s)^#hoRR00t zgD2d6H1N!x#lvwA^9j#T2LLXbVjYxdj=phhEBSEXccLZt^#7ivoKq|7dJ3$A3iwBB zts2s5K?&i-N+Y7<-|tvG2pjTaPjmNwkQvfm#ot-+|0e5N#gq$EB>1UT$-{At%HoFk zh1YM!A1<>fHcx&lNH#&;j#W8O!x+b3DYf&(K@#^ z-96e-P}gG;+m>{1sa}rnKdU;Iepj@pkX_8+ztn{MMK1yMo5%YY@c8~SwENHTj?<_A zD3GioPc`SAh7O+4rFFy-(fgD7IVK|u3<4|dS~n&1ORQy z=LUS4B{|dP!8V|L_%u_T%tnv~KJ_qis{8GC1O8(G<~ANCUE24)YY)d)lA>K!qjQTY zom&*hxh(Z{+qC)VhI@oPQ~bfCIP9RViVvHTYQ}$5+XMhxR1CJ%R>5?&8$4+?X5xK! zt48UTiQGchwBysHr%7ejRIYrgTjwfg-&3WH*h>~mZQGyl^ow>$ux8SO^PN)WaQX^6 za)Iau-$L{(Eth;^Opsesu6bx9iV;PzWZdVO;r$q(@}Kqp>G=W)0$?BcaCkuvk|-H*&QdkjHP4fV8jfJ3h_Q-bc;OqlPlK!3;%DWFf^>yHp`#QEw7=mO^aB7 zCOcx=KGwF;oWdO-(y#*D$|PZ%U+?u*Dhw*=$X!NS*wCbgcb2~vyRcn_dD7G+uDd$6 z9F*2IsOcFP2v?v6eas4;$v1yGnWGj(5YQ{(UYV7b@rz1+Xhc~dJt?4(&jrF zuHova6|g2;-I`ubN&lLn@V*`2Q3)qf%;EJm%%sL6+3kUGp=bjAes(4@1qDjtrk%Ji z&*Dm;(P7wf+jO%53U82rJ=F`dV+k|~;$FAU)M=kNleOwkN?kK;OaqKqmOlkMRIWRn zgv^Qn62rRoOY8OoAu(oY4R?=E`b=*!2dXf-lcdb)2&w+Ck3j~RCkNRQ9MM0NH_V?2 zFvL@bUKEwWK&F!x%-&?DEwHu~Ta>UwA^r0KDP@)D9eo9&Of;I{6e%pC-w)ini(SC| zMTAtaxN7^K<>g)V_EV_Va*g|OW%Lb`*0Y4?K>E)~i}%|fpPD1aV)eG;5c-!_*(UeG z2ZNa8WaImbee@@xDA^;e6g!T(;<y3U0QLuZiEo*e>9 zzgBc*c&y{JxkUz1L};{dOcd6h8&gU{r07Dj2Hhb|f0LzElBLY1S&FftYS_ES`98qWnHLFI>d_tkhJutoe_~3m)sQz9?pr2m0uHHn5oF30@$GwM^nt zQc~}}St+5#YL~juW3U}xgJan~$J5T+rcM_c&p0UvU?zi2`}gNAt+LwT@9r*BY4QB! z-(*hP!Q1qM&GN;U z>pHCm8ds}&iFX_c!9W>(dlMmu6=-%ok*SA8<(Y zL%^_Z&SZwygJ+e%5Jfm&-M>C#_c{-f4SAz?^tQui;F*tIhQ~5dPt%Gg!ql=p#>tVQ>Zkc63`hA=WG)A#;{TI>ER zlNV(j4icnxi_ewVy`P@Dp<^Mixu$^0GmexPGog9xy|m``{ai}jwMP+}`U zWUu^lZ3)2}1*$0ZPJFB#{r}M=`^qF2UKV!Y&FJ{N2yOssGG2Vht#9b+Mp7}PUe$$x3@$!2K*umMjFwys<;y04^@+TwEC2a+k%IUQ zIq{NZj}|c&M!N;zF%NFV-YNlh8RwFd}UD8uV(nNo0j zuV+TM!=aC<$c_Qe*Y|ZrMf*Nuk~zfmCKW#R>9f@ljXvOxaU8th_e`@T`#}@{%qbWC zsnnxeS8p27DbDjtPfS*%2wSz*d}EJBKV1ttE(S!!x!qmD>VxRs=qaUDCLv9u=tiZ;}>iSq2Y;r7!y0_h+7LcSWaXR$9E{GV1_ z_xNl9#7ggI*UJd8kHCuwelX`^wr`CKts(K`0EUnZcEL3&2`XQr8HLB>$EHg;j)z;x z@iQW<#@J-^P7PjYIjBq=1b?f9!WM_8E3vbc+2DTxY5@|Ld7L{`aTb@RL_)g@(8x%;4g8?vi@7VK9FST zGKo;W%kSwZ_QSOPh6C9Dof`ee^lU46d1*qXO^v5PK`Ji{1>p4EG^qf;S)}93<6-d96g#idMq9F2)~<1)AnJI8kJ)wahJTeA z>+-NQ(51jW6dt{aHAWL|MQlWRzXCj9TI0L={y|R3@Gv)3P{bm-O+QJ0*45zRn25xM zhx1|1E7Z;y;ZBOPU+d31+nlRkz@g?nF`XEh;>^)Z@xmOjoKw)pGZ$rI+Cd?TjJaoI0aIm<%jW!r zWB7V!ftr576vJ}f-&(y2L%~_AW!<5%VV4n5V;=Q>G<5s#@Jj6OpbwaUruIM1!|(Sj z0z*rHx}-Cs$isR$98Z2H8zoZCVhv~$rn&T0V{-bD({|ajqRfix{J5Oj2V>KLaj7Xb z!81XI&ue+dBb>&rQvE_m;;fS&4FuSB@WI-DcN%6~K1_oU_DR+cMjkf$Ckh|YcUA|g zMC?7=*(TC#p$y648u52l&O0%A>Ch^ge4U9!?1}gzfk?0DAmk+A`_t3ve&_oE5Bvul zCi+9N{ZEL~hmEfj)Rdk{OAl4#^W$v%=Zjz9ftigt1&VrRJ)UJD3di-| zoWYhi4gl4wD|{;2`{WhsSWZ2NTV(fD4T96k=)Yh*QhmFgUjbxr zKTlkOCKT1~1eyR+_XqvL`1d{EkS-nF24R89X-IVPi_#~E))l>3jJyBhK3$DufqP)E zPWVvrL4fe$Pc^wZM;g47e6FT;Fo?C@DO<-J7lt5D7S%RTJ9Rx+0#!WHxAlu{n;v_( z`L*w{Dva^>J%6YW)xi=iaig_=th3b#$2^}n7R}{h7Mgwm1+@O#!eSFb&jLF7|B`ov z{C9*2{~w6zN{`vnW@pmNlg3_sqz94`B+V;kW>==4yEXp?mww+reJ0PikA3L9BUU;L zoq2iGFE-yo^ETGuuq@?NK3p>qq}%+#nb0PKd7iqSX9}(#m6;XO@BM2TuR)V1FCjZ-+b`ceR2ym4oQ?)D?y-qD;RP z`}S<6Q`^8BP1;ams(Q19YHqgU>v?CZBtr9LotUo7fJ(nmE_vc_%$KA|R6UN2c@d@R z#sN~Ot?tmbRHLfF`;~MaX2RK`3P85KnB9j1Jt@T>?d$HA?%(|n=M!^ui_7JPv8-)6vB#+?k3&`>_Y&B z>jEx}`{8&t*f6K^Ye5kG(PsZ~(}HlH;pOR%O!Oi}*reHI#hoa4bitI*Ut-K3GVywf zC>Y)SgkD->ds&?%MaQQWHUb{Ce~3qwT~2^KO=@(NM;}28$={LVasngJz0?Ca#jR`* zJdJZ3CWJpzqxmmEO|uRnRkNm}uS|Z6RP;4{{c*<+Q*+g;#{Zp}ie+=?r2@)`;)T~MpF< z8f}Kt)^~%=)e0H89>^rna4Yl?0=5jJ;C>7AQ~-8`yda2tfjZQEnuTqEBUN$W zWgZexM0&c`nCnl_EQm}-tBS(DO>g2JfeMbmblq3C-CI3S0^3+aPf7;{WncARXYH+!bTnuyGwU}P+wzKNB< zS75Hr%m^hneSq?@V~`>1L%lg;N&Z|m+GM=cTK{McN}Eh8Sb8poAb?n*XwU7`{dEEB zRQ;PM6Uk6JztVl_%D=+5aC-}1fp;=Ym|u3H!#OPqIf$_qlz@y7V@)?g5>^dy|5r2D z8r0Oag@fK+r-fc|coh(=)dB^o1*#=i5Tz&xC=E153YaShC?+6eAVP>bR;v=g`T(Ix z)v7!URvUqYw^)sqpaBX3CJ-u>oW0Ikd+oi} z_kAy&d@YZ2Ga-&j2wbayKh7P`us}ngOt3J_1dBq4&DS7N{G8vJI=_7UIfW%f8ypM1 z8x018#T>wyS=6J-Fp6~oi&V6l6`n0gv5b-5%<#=-X{mRzm~IY(I(4QhRcu8TXe86Z zE`oa)d1$usE7vR~exU1MPVy*XQhylhKBPw!Yi-LYKgI>W_NK=)^kZp?f@(%25H4uB zW7N{IHl#d2U8abqN`ZstpIj86ueQ{$`R+?p$d&by7+(q)K7 zLl`-wG>#@p0+-s8B`EN^6UG>?zAC5Cgv?kQIMTfj< zLtxK22*b+|_4lwvXI5VGS0@F%gZqPP8DnMhQ*vkTs)ZKW%JEKd7==`Vt^O&PW#&M_ zV=Byfo#Delw)*q74LRl9r`54faQ^XlvJd+|E&K9A*!>vWidrt^u4iO+DraqjN<{%| zu2)WIeZZ;T-F?;X6GS^2d+fsOdq%Y#dfmvCRx|{qHyJQ*uaxrUJBxpRB=Kv7CI4Rs zYyGX8R6Oj{@X=O%8y+7lmkGUl09lN?wB*=z=Y6-*)1neBB5;Slq9+K>SDgnK@dDh( z+#?Rh5!VNY%i(gGo+6b1+=eU8@hLA5t{c}{Dk@yMe(u(kxmz1gs$XgDe)*w)nRC43 zzx7=oNBQi~Oo?OzB{JQFKjU`(0G$JcU!#5#(XAI_Gj%g@7(|#6k{?E-NYAAAml_Y9 zlCLD}p|PPBx1cdR84l*Re!8zdyCX3qh^KwIv)Y9DUAEGHyZhp-sVyJyh|t7-=DUtjejBKIKj4@i`)vG;FK#rHui zF2m9D9>1+1)2do>NX`O*)>zA@?1SE0_1EpnKOvpK-)<0$7svHbX`@fbpVCHkk&8xZ zb!Yn?T95_Oq(YaL18W_r(OCd*pgc<(Zp9UCyGOYwfX= zk2rlt*c?`=MEq-RZ-estr82FTQ=w-3>ivN)kEBnkHYU0h06>{ag0*_bsH)dnFO-*e1>gX9V@@>NfI}K@&adi45-K z^+Lnz6u6wub3IFlo3wlEln+!JPtqRag!k17{OsTtA#hwQ7n9rjLU)!i!<{rK8DC3f zDk3EbG{G9JdCy~v_TH$l=Xd9drnqw3ZSeksH-`n&x!*@e0GP5ryTIj2eFLZXK;2$m z6tOslA;v52SxM`&-`d9}UgXt>FNG0Jg=xWiE0L&xYJtw!tM*Y6>kDR#J9@lhD)x%VxWOz@5i%44>S>7mJ~BdYm5`d zSeLCI0In*`>%uycc#S|`VJ;1@Y}roy=M0PD;&bHd;pX9u=2ABlT!cIid?s>B+@8;$ z1^){*I*f2OMEu#iNJR^Gcr#Hv_$z7({ZF^5mXS-1zoA^1kJI()yqc>`Lnj&4ScE#h zRY*@GwMk%9wt>x>!G;KOp}li&|&r3P2yw9>JPMxAo)X+M2-^e9JU$8aNMhj zB`0W3E%%dzGW>;W+gEMCbj`Q@tbXWJNuO{#8bFMbzTD1vS9hrXw0aOd_&xfW(E=cO z`KuDCgMx{b)H@dFS=H?o$I@T4LJu#)VJcxRSoGaS6!H P + + + 4.0.0 + + org.apache.dolphinscheduler + dolphinscheduler-alert-plugins + dev-SNAPSHOT + + + dolphinscheduler-alert-aliyunVoice + jar + + + + org.apache.dolphinscheduler + dolphinscheduler-alert-api + + + com.aliyun + dyvmsapi20170525 + + + diff --git a/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/main/java/org/apache/dolphinscheduler/plugin/alert/voice/VoiceAlertChannel.java b/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/main/java/org/apache/dolphinscheduler/plugin/alert/voice/VoiceAlertChannel.java new file mode 100644 index 0000000000..eeaaba5d01 --- /dev/null +++ b/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/main/java/org/apache/dolphinscheduler/plugin/alert/voice/VoiceAlertChannel.java @@ -0,0 +1,70 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.dolphinscheduler.plugin.alert.voice; + +import static org.apache.dolphinscheduler.plugin.alert.voice.VoiceAlertConstants.NAME_ACCESS_KEY_ID; +import static org.apache.dolphinscheduler.plugin.alert.voice.VoiceAlertConstants.NAME_ACCESS_KEY_SECRET; +import static org.apache.dolphinscheduler.plugin.alert.voice.VoiceAlertConstants.NAME_ADDRESS; +import static org.apache.dolphinscheduler.plugin.alert.voice.VoiceAlertConstants.NAME_CALLED_NUMBER; +import static org.apache.dolphinscheduler.plugin.alert.voice.VoiceAlertConstants.NAME_CALLED_SHOW_NUMBER; +import static org.apache.dolphinscheduler.plugin.alert.voice.VoiceAlertConstants.NAME_TTS_CODE; + +import org.apache.dolphinscheduler.alert.api.AlertChannel; +import org.apache.dolphinscheduler.alert.api.AlertInfo; +import org.apache.dolphinscheduler.alert.api.AlertResult; + +import java.util.Map; + +import lombok.extern.slf4j.Slf4j; + +@Slf4j +public final class VoiceAlertChannel implements AlertChannel { + + @Override + public AlertResult process(AlertInfo info) { + + Map paramsMap = info.getAlertParams(); + if (null == paramsMap) { + return new AlertResult("false", "aliyun-voice params is null"); + } + VoiceParam voiceParam = buildVoiceParam(paramsMap); + return new VoiceSender(voiceParam).send(); + } + + public VoiceParam buildVoiceParam(Map paramsMap) { + String calledNumber = paramsMap.get(NAME_CALLED_NUMBER); + String calledShowNumber = paramsMap.get(NAME_CALLED_SHOW_NUMBER); + String ttsCode = paramsMap.get(NAME_TTS_CODE); + VoiceParam param = new VoiceParam(); + param.setCalledNumber(calledNumber); + param.setCalledShowNumber(calledShowNumber); + param.setTtsCode(ttsCode); + VoiceParam.Connection connection = new VoiceParam.Connection(); + String address = paramsMap.get(NAME_ADDRESS); + String accessKeyId = paramsMap.get(NAME_ACCESS_KEY_ID); + String accessKeySecret = paramsMap.get(NAME_ACCESS_KEY_SECRET); + connection.setAddress(address); + connection.setAccessKeyId(accessKeyId); + connection.setAccessKeySecret(accessKeySecret); + param.setConnection(connection); + + // set callback ID + param.setOutId(calledShowNumber); + return param; + } +} diff --git a/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/main/java/org/apache/dolphinscheduler/plugin/alert/voice/VoiceAlertChannelFactory.java b/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/main/java/org/apache/dolphinscheduler/plugin/alert/voice/VoiceAlertChannelFactory.java new file mode 100644 index 0000000000..2fb5820e37 --- /dev/null +++ b/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/main/java/org/apache/dolphinscheduler/plugin/alert/voice/VoiceAlertChannelFactory.java @@ -0,0 +1,95 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.dolphinscheduler.plugin.alert.voice; + +import org.apache.dolphinscheduler.alert.api.AlertChannel; +import org.apache.dolphinscheduler.alert.api.AlertChannelFactory; +import org.apache.dolphinscheduler.alert.api.AlertInputTips; +import org.apache.dolphinscheduler.spi.params.base.PluginParams; +import org.apache.dolphinscheduler.spi.params.base.Validate; +import org.apache.dolphinscheduler.spi.params.input.InputParam; + +import java.util.Arrays; +import java.util.List; + +import com.google.auto.service.AutoService; + +@AutoService(AlertChannelFactory.class) +public final class VoiceAlertChannelFactory implements AlertChannelFactory { + + @Override + public String name() { + return "AliyunVoice"; + } + + @Override + public List params() { + + InputParam calledNumber = + InputParam.newBuilder(VoiceAlertConstants.NAME_CALLED_NUMBER, VoiceAlertConstants.CALLED_NUMBER) + .setPlaceholder(AlertInputTips.CALLED_NUMBER.getMsg()) + .addValidate(Validate.newBuilder() + .setRequired(true) + .build()) + .build(); + + InputParam calledShowNumber = InputParam + .newBuilder(VoiceAlertConstants.NAME_CALLED_SHOW_NUMBER, VoiceAlertConstants.CALLED_SHOW_NUMBER) + .setPlaceholder(AlertInputTips.CALLED_SHOW_NUMBER.getMsg()) + .addValidate(Validate.newBuilder() + .setRequired(false) + .build()) + .build(); + + InputParam ttsCode = InputParam.newBuilder(VoiceAlertConstants.NAME_TTS_CODE, VoiceAlertConstants.TTS_CODE) + .setPlaceholder(AlertInputTips.TTS_CODE.getMsg()) + .addValidate(Validate.newBuilder() + .setRequired(false) + .build()) + .build(); + + InputParam address = InputParam.newBuilder(VoiceAlertConstants.NAME_ADDRESS, VoiceAlertConstants.ADDRESS) + .setPlaceholder(AlertInputTips.ALIYUN_VIICE_ADDRESS.getMsg()) + .addValidate(Validate.newBuilder() + .setRequired(false) + .build()) + .build(); + + InputParam accessKeyId = + InputParam.newBuilder(VoiceAlertConstants.NAME_ACCESS_KEY_ID, VoiceAlertConstants.ACCESS_KEY_ID) + .setPlaceholder(AlertInputTips.ALIYUN_VIICE_ACCESSKEYID.getMsg()) + .addValidate(Validate.newBuilder() + .setRequired(false) + .build()) + .build(); + InputParam accessKeySecret = + InputParam.newBuilder(VoiceAlertConstants.NAME_ACCESS_KEY_SECRET, VoiceAlertConstants.ACCESS_KEY_SECRET) + .setPlaceholder(AlertInputTips.ALIYUN_VIICE_ACCESSKEY_SECRET.getMsg()) + .addValidate(Validate.newBuilder() + .setRequired(false) + .build()) + .build(); + + return Arrays.asList(calledNumber, calledShowNumber, ttsCode, address, accessKeyId, accessKeySecret); + } + + @Override + public AlertChannel create() { + return new VoiceAlertChannel(); + } +} diff --git a/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/main/java/org/apache/dolphinscheduler/plugin/alert/voice/VoiceAlertConstants.java b/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/main/java/org/apache/dolphinscheduler/plugin/alert/voice/VoiceAlertConstants.java new file mode 100644 index 0000000000..fabeac07cc --- /dev/null +++ b/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/main/java/org/apache/dolphinscheduler/plugin/alert/voice/VoiceAlertConstants.java @@ -0,0 +1,79 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.dolphinscheduler.plugin.alert.voice; + +public class VoiceAlertConstants { + + /** + * called Number + */ + static final String NAME_CALLED_NUMBER = "calledNumber"; + /** + * called Number + */ + static final String CALLED_NUMBER = "$t('calledNumber')"; + /** + * called Show Number + */ + static final String NAME_CALLED_SHOW_NUMBER = "calledShowNumber"; + /** + * called Show Number + */ + static final String CALLED_SHOW_NUMBER = "$t('calledShowNumber')"; + /** + * tts Code + */ + static final String NAME_TTS_CODE = "ttsCode"; + /** + * tts Code + */ + static final String TTS_CODE = "$t('ttsCode')"; + /** + * tts Param + */ + static final String TTS_PARAM = "ttsParam"; + + /** + * address + */ + static final String NAME_ADDRESS = "address"; + /** + * address + */ + static final String ADDRESS = "$t('address')"; + /** + * accessKeyId + */ + static final String NAME_ACCESS_KEY_ID = "accessKeyId"; + /** + * accessKeyId + */ + static final String ACCESS_KEY_ID = "$t('accessKeyId')"; + /** + * accessKeySecret + */ + static final String NAME_ACCESS_KEY_SECRET = "accessKeySecret"; + /** + * accessKeySecret + */ + static final String ACCESS_KEY_SECRET = "$t('accessKeySecret')"; + + private VoiceAlertConstants() { + throw new UnsupportedOperationException("This is a utility class and cannot be instantiated"); + } +} diff --git a/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/main/java/org/apache/dolphinscheduler/plugin/alert/voice/VoiceParam.java b/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/main/java/org/apache/dolphinscheduler/plugin/alert/voice/VoiceParam.java new file mode 100644 index 0000000000..2e07f54fd8 --- /dev/null +++ b/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/main/java/org/apache/dolphinscheduler/plugin/alert/voice/VoiceParam.java @@ -0,0 +1,74 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.dolphinscheduler.plugin.alert.voice; + +import lombok.Data; + +@Data +public class VoiceParam { + + /** + * called Number + */ + private String calledNumber; + /** + * called Show Number + */ + private String calledShowNumber; + /** + * tts code + */ + private String ttsCode; + /** + * tts param + */ + private String ttsParam; + + /** + * connection info + */ + private Connection connection; + + /** + * outId + */ + private String outId; + + @Data + public static class Connection { + + /** + * address + */ + private String address; + + /** + * accessKeyId + */ + private String accessKeyId; + /** + * accessKeySecret + */ + private String accessKeySecret; + + /** + * tts Code + */ + private String ttsCode; + } +} diff --git a/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/main/java/org/apache/dolphinscheduler/plugin/alert/voice/VoiceSender.java b/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/main/java/org/apache/dolphinscheduler/plugin/alert/voice/VoiceSender.java new file mode 100644 index 0000000000..c6c29d8735 --- /dev/null +++ b/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/main/java/org/apache/dolphinscheduler/plugin/alert/voice/VoiceSender.java @@ -0,0 +1,101 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.dolphinscheduler.plugin.alert.voice; + +import org.apache.dolphinscheduler.alert.api.AlertResult; + +import lombok.extern.slf4j.Slf4j; + +import com.aliyun.dyvmsapi20170525.Client; +import com.aliyun.dyvmsapi20170525.models.SingleCallByTtsRequest; +import com.aliyun.dyvmsapi20170525.models.SingleCallByTtsResponse; +import com.aliyun.dyvmsapi20170525.models.SingleCallByTtsResponseBody; +import com.aliyun.teaopenapi.models.Config; +import com.aliyun.teautil.models.RuntimeOptions; + +@Slf4j +public final class VoiceSender { + + private VoiceParam voiceParam; + + /** + * create Client + * + * @param voiceParam voidce Param + * @return Client + * @throws Exception + */ + public VoiceSender(VoiceParam voiceParam) { + this.voiceParam = voiceParam; + } + + public AlertResult send() { + AlertResult alertResult = new AlertResult(); + alertResult.setStatus("false"); + try { + Client client = createClient(voiceParam.getConnection()); + SingleCallByTtsRequest singleCallByTtsRequest = new SingleCallByTtsRequest() + .setCalledNumber(voiceParam.getCalledNumber()) + .setTtsCode(voiceParam.getTtsCode()) + .setOutId(voiceParam.getOutId()); + RuntimeOptions runtime = new RuntimeOptions(); + SingleCallByTtsResponse response = client.singleCallByTtsWithOptions(singleCallByTtsRequest, runtime); + if (response == null) { + alertResult.setMessage("aliyun-vocie response is null"); + return alertResult; + } + SingleCallByTtsResponseBody body = response.getBody(); + if (body.code.equalsIgnoreCase("ok")) { + alertResult.setStatus("true"); + alertResult.setMessage(body.getCallId()); + } else { + alertResult.setMessage(body.getMessage()); + } + } catch (Exception e) { + log.error("send aliyun vocie error.", e); + alertResult.setMessage(e.getMessage()); + } + return alertResult; + } + + /** + * create Client + * + * @param conn conn info + * @return Client + * @throws Exception + */ + private com.aliyun.dyvmsapi20170525.Client createClient(VoiceParam.Connection conn) throws Exception { + Config config = new Config() + // AccessKey ID + .setAccessKeyId(conn.getAccessKeyId()) + // AccessKey Secret + .setAccessKeySecret(conn.getAccessKeySecret()); + // address + config.endpoint = conn.getAddress(); + return new com.aliyun.dyvmsapi20170525.Client(config); + } + + public VoiceParam getVoidcePara() { + return voiceParam; + } + + public void setVoidcePara(VoiceParam voidcePara) { + this.voiceParam = voidcePara; + } +} diff --git a/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/test/java/VoiceAlertChannelFactoryTest.java b/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/test/java/VoiceAlertChannelFactoryTest.java new file mode 100644 index 0000000000..732c91dfea --- /dev/null +++ b/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/test/java/VoiceAlertChannelFactoryTest.java @@ -0,0 +1,47 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +import org.apache.dolphinscheduler.alert.api.AlertChannel; +import org.apache.dolphinscheduler.common.utils.JSONUtils; +import org.apache.dolphinscheduler.plugin.alert.voice.VoiceAlertChannelFactory; +import org.apache.dolphinscheduler.spi.params.base.PluginParams; + +import java.util.List; + +import org.junit.jupiter.api.Assertions; +import org.junit.jupiter.api.Test; + +/** + * VoiceAlertChannelFactoryTest + */ +class VoiceAlertChannelFactoryTest { + + @Test + void testGetParams() { + VoiceAlertChannelFactory voiceAlertChannelFactory = new VoiceAlertChannelFactory(); + List params = voiceAlertChannelFactory.params(); + JSONUtils.toJsonString(params); + Assertions.assertEquals(6, params.size()); + } + + @Test + void testCreate() { + VoiceAlertChannelFactory voiceAlertChannelFactory = new VoiceAlertChannelFactory(); + AlertChannel alertChannel = voiceAlertChannelFactory.create(); + Assertions.assertNotNull(alertChannel); + } +} diff --git a/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/test/java/VoiceSenderTest.java b/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/test/java/VoiceSenderTest.java new file mode 100644 index 0000000000..515a410b63 --- /dev/null +++ b/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-aliyunVoice/src/test/java/VoiceSenderTest.java @@ -0,0 +1,52 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +import org.apache.dolphinscheduler.alert.api.AlertResult; +import org.apache.dolphinscheduler.plugin.alert.voice.VoiceParam; +import org.apache.dolphinscheduler.plugin.alert.voice.VoiceSender; + +import org.junit.jupiter.api.Assertions; +import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.Test; + +/** + * VoiceSenderTest + */ +class VoiceSenderTest { + + private static VoiceParam voiceParam = new VoiceParam(); + + @BeforeEach + void initVoidceParam() { + voiceParam.setCalledNumber("12345678910"); + voiceParam.setTtsParam("TTS_2450XXXXX"); + VoiceParam.Connection connection = new VoiceParam.Connection(); + connection.setAddress("xxxxxx.aliyuncs.com"); + connection.setAccessKeyId("XXXXXXXXX"); + connection.setAccessKeySecret("XXXXXXXXX"); + voiceParam.setConnection(connection); + } + + @Test + void testSendWeChatTableMsg() { + VoiceSender weChatSender = new VoiceSender(voiceParam); + + AlertResult alertResult = weChatSender.send(); + Assertions.assertEquals("false", alertResult.getStatus()); + } + +} diff --git a/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-all/pom.xml b/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-all/pom.xml index ec8f53fd41..136ebffb53 100644 --- a/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-all/pom.xml +++ b/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-all/pom.xml @@ -82,7 +82,11 @@ dolphinscheduler-alert-wechat ${project.version} - + + org.apache.dolphinscheduler + dolphinscheduler-alert-aliyunVoice + ${project.version} + diff --git a/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-api/src/main/java/org/apache/dolphinscheduler/alert/api/AlertInputTips.java b/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-api/src/main/java/org/apache/dolphinscheduler/alert/api/AlertInputTips.java index ec8f4184e0..3f3070f35a 100644 --- a/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-api/src/main/java/org/apache/dolphinscheduler/alert/api/AlertInputTips.java +++ b/dolphinscheduler-alert/dolphinscheduler-alert-plugins/dolphinscheduler-alert-api/src/main/java/org/apache/dolphinscheduler/alert/api/AlertInputTips.java @@ -50,6 +50,13 @@ public enum AlertInputTips { SECRET("please input secret", "请输入secret"), WECHAT_MENTION_USERS("use `|` to separate userIds and `@all` to everyone", "使用`|`来分割userId或使用`@all`来提到所有人"), WECHAT_AGENT_ID("please input agent id or chat id", "请输入agent id或chat id"), + CALLED_NUMBER("please input called number", "请输入被叫电话号码"), + CALLED_SHOW_NUMBER("Please enter the call display number (the default number will be used if you do not fill in)", + "请输入呼叫显示号码(不填则使用默认号码)"), + TTS_CODE("please input tts code", "请输入语音模板编码"), + ALIYUN_VIICE_ADDRESS("please input aliyun viice address", "请输入阿里云访问域名"), + ALIYUN_VIICE_ACCESSKEYID("please input accessKeyId", "请输入accessKeyId"), + ALIYUN_VIICE_ACCESSKEY_SECRET("please input accessKeySecret", "请输入accessKeySecret"), ANNOTATION("please input annotation in json form", "请输入json格式的annotation"), GENERATOR_URL("please input Generator URL", "请输入生成地址"); diff --git a/dolphinscheduler-alert/dolphinscheduler-alert-plugins/pom.xml b/dolphinscheduler-alert/dolphinscheduler-alert-plugins/pom.xml index e60d4e7049..96f92922ce 100644 --- a/dolphinscheduler-alert/dolphinscheduler-alert-plugins/pom.xml +++ b/dolphinscheduler-alert/dolphinscheduler-alert-plugins/pom.xml @@ -39,6 +39,7 @@ dolphinscheduler-alert-pagerduty dolphinscheduler-alert-webexteams dolphinscheduler-alert-telegram + dolphinscheduler-alert-aliyunVoice dolphinscheduler-alert-prometheus diff --git a/dolphinscheduler-bom/pom.xml b/dolphinscheduler-bom/pom.xml index 8829cdec3a..d4d4ee828f 100644 --- a/dolphinscheduler-bom/pom.xml +++ b/dolphinscheduler-bom/pom.xml @@ -122,6 +122,7 @@ 1.17.6 3.19.0 0.10.1 + 2.1.4 @@ -960,7 +961,11 @@ checker-qual ${checker-qual.version} - + + com.aliyun + dyvmsapi20170525 + ${aliyun-voice.version} + diff --git a/dolphinscheduler-dist/release-docs/LICENSE b/dolphinscheduler-dist/release-docs/LICENSE index 94ec6048a5..1284cd3319 100644 --- a/dolphinscheduler-dist/release-docs/LICENSE +++ b/dolphinscheduler-dist/release-docs/LICENSE @@ -562,6 +562,19 @@ The text of each license is also included at licenses/LICENSE-[project].txt. org.apache.oltu.oauth2.client 1.0.2 https://mvnrepository.com/artifact/org.apache.oltu.oauth2/org.apache.oltu.oauth2.client/1.0.2 Apache 2.0 org.apache.oltu.oauth2.common 1.0.2 https://mvnrepository.com/artifact/org.apache.oltu.oauth2/org.apache.oltu.oauth2.common/1.0.2 Apache 2.0 esdk-obs-java-bundle 3.23.3 https://mvnrepository.com/artifact/com.huaweicloud/esdk-obs-java-bundle/3.23.3 Apache 2.0 + dyvmsapi20170525 2.1.4 https://github.com/aliyun/aliyun-openapi-java-sdk/blob/master/README.md#license Apache 2.0 + alibabacloud-gateway-spi 0.0.1 https://github.com/aliyun/aliyun-openapi-java-sdk/blob/master/README.md#license Apache 2.0 + credentials-java 0.2.2 https://github.com/aliyun/aliyun-openapi-java-sdk/blob/master/README.md#license Apache 2.0 + endpoint-util 0.0.7 https://github.com/aliyun/aliyun-openapi-java-sdk/blob/master/README.md#license Apache 2.0 + openapiutil 0.1.14 https://github.com/aliyun/aliyun-openapi-java-sdk/blob/master/README.md#license Apache 2.0 + tea-1.1.14.jar https://github.com/aliyun/aliyun-openapi-java-sdk/blob/master/README.md#license Apache 2.0 + tea-openapi 0.2.2.jar https://github.com/aliyun/aliyun-openapi-java-sdk/blob/master/README.md#license Apache 2.0 + tea-rpc 0.0.11.jar https://github.com/aliyun/aliyun-openapi-java-sdk/blob/master/README.md#license Apache 2.0 + tea-rpc-util 0.1.3.jar https://github.com/aliyun/aliyun-openapi-java-sdk/blob/master/README.md#license Apache 2.0 + tea-util 0.2.13.jar https://github.com/aliyun/aliyun-openapi-java-sdk/blob/master/README.md#license Apache 2.0 + + + @@ -602,6 +615,7 @@ The text of each license is also included at licenses/LICENSE-[project].txt. google-auth-library-credentials 1.15.0: https://mvnrepository.com/artifact/com.google.auth/google-auth-library-credentials/1.15.0, BSD 3-clause google-auth-library-oauth2-http 1.15.0: https://mvnrepository.com/artifact/com.google.auth/google-auth-library-oauth2-http/1.15.0, BSD 3-clause threetenbp 1.6.5: https://mvnrepository.com/artifact/org.threeten/threetenbp/1.6.5, BSD 3-clause + dom4j 2.1.3 https://github.com/dom4j/dom4j/blob/master/LICENSE BSD 3-clause ======================================================================== CDDL licenses @@ -624,7 +638,8 @@ The text of each license is also included at licenses/LICENSE-[project].txt. jta 1.1: https://mvnrepository.com/artifact/javax.transaction/jta/1.1, CDDL 1.0 transaction-api 1.1: https://mvnrepository.com/artifact/javax.transaction/transaction-api/1.1, CDDL 1.0 javax.el 3.0.0: https://mvnrepository.com/artifact/org.glassfish/javax.el/3.0.0, CDDL and GPL and GPL 2.0 - + jaxb-core 2.3.0 https://mvnrepository.com/artifact/com.sun.xml.bind/jaxb-core/2.3.0 GPL 1.1 + jaxb-impl 2.3.0 https://mvnrepository.com/artifact/com.sun.xml.bind/jaxb-impl/2.3.0 GPL 1.1 ======================================================================== EPL licenses ======================================================================== diff --git a/dolphinscheduler-dist/release-docs/licenses/LICENSE-dyvmsapi20170525.txt b/dolphinscheduler-dist/release-docs/licenses/LICENSE-dyvmsapi20170525.txt new file mode 100644 index 0000000000..d645695673 --- /dev/null +++ b/dolphinscheduler-dist/release-docs/licenses/LICENSE-dyvmsapi20170525.txt @@ -0,0 +1,202 @@ + + Apache License + Version 2.0, January 2004 + http://www.apache.org/licenses/ + + TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION + + 1. Definitions. + + "License" shall mean the terms and conditions for use, reproduction, + and distribution as defined by Sections 1 through 9 of this document. + + "Licensor" shall mean the copyright owner or entity authorized by + the copyright owner that is granting the License. + + "Legal Entity" shall mean the union of the acting entity and all + other entities that control, are controlled by, or are under common + control with that entity. For the purposes of this definition, + "control" means (i) the power, direct or indirect, to cause the + direction or management of such entity, whether by contract or + otherwise, or (ii) ownership of fifty percent (50%) or more of the + outstanding shares, or (iii) beneficial ownership of such entity. + + "You" (or "Your") shall mean an individual or Legal Entity + exercising permissions granted by this License. + + "Source" form shall mean the preferred form for making modifications, + including but not limited to software source code, documentation + source, and configuration files. + + "Object" form shall mean any form resulting from mechanical + transformation or translation of a Source form, including but + not limited to compiled object code, generated documentation, + and conversions to other media types. + + "Work" shall mean the work of authorship, whether in Source or + Object form, made available under the License, as indicated by a + copyright notice that is included in or attached to the work + (an example is provided in the Appendix below). + + "Derivative Works" shall mean any work, whether in Source or Object + form, that is based on (or derived from) the Work and for which the + editorial revisions, annotations, elaborations, or other modifications + represent, as a whole, an original work of authorship. For the purposes + of this License, Derivative Works shall not include works that remain + separable from, or merely link (or bind by name) to the interfaces of, + the Work and Derivative Works thereof. + + "Contribution" shall mean any work of authorship, including + the original version of the Work and any modifications or additions + to that Work or Derivative Works thereof, that is intentionally + submitted to Licensor for inclusion in the Work by the copyright owner + or by an individual or Legal Entity authorized to submit on behalf of + the copyright owner. For the purposes of this definition, "submitted" + means any form of electronic, verbal, or written communication sent + to the Licensor or its representatives, including but not limited to + communication on electronic mailing lists, source code control systems, + and issue tracking systems that are managed by, or on behalf of, the + Licensor for the purpose of discussing and improving the Work, but + excluding communication that is conspicuously marked or otherwise + designated in writing by the copyright owner as "Not a Contribution." + + "Contributor" shall mean Licensor and any individual or Legal Entity + on behalf of whom a Contribution has been received by Licensor and + subsequently incorporated within the Work. + + 2. Grant of Copyright License. Subject to the terms and conditions of + this License, each Contributor hereby grants to You a perpetual, + worldwide, non-exclusive, no-charge, royalty-free, irrevocable + copyright license to reproduce, prepare Derivative Works of, + publicly display, publicly perform, sublicense, and distribute the + Work and such Derivative Works in Source or Object form. + + 3. Grant of Patent License. Subject to the terms and conditions of + this License, each Contributor hereby grants to You a perpetual, + worldwide, non-exclusive, no-charge, royalty-free, irrevocable + (except as stated in this section) patent license to make, have made, + use, offer to sell, sell, import, and otherwise transfer the Work, + where such license applies only to those patent claims licensable + by such Contributor that are necessarily infringed by their + Contribution(s) alone or by combination of their Contribution(s) + with the Work to which such Contribution(s) was submitted. If You + institute patent litigation against any entity (including a + cross-claim or counterclaim in a lawsuit) alleging that the Work + or a Contribution incorporated within the Work constitutes direct + or contributory patent infringement, then any patent licenses + granted to You under this License for that Work shall terminate + as of the date such litigation is filed. + + 4. Redistribution. You may reproduce and distribute copies of the + Work or Derivative Works thereof in any medium, with or without + modifications, and in Source or Object form, provided that You + meet the following conditions: + + (a) You must give any other recipients of the Work or + Derivative Works a copy of this License; and + + (b) You must cause any modified files to carry prominent notices + stating that You changed the files; and + + (c) You must retain, in the Source form of any Derivative Works + that You distribute, all copyright, patent, trademark, and + attribution notices from the Source form of the Work, + excluding those notices that do not pertain to any part of + the Derivative Works; and + + (d) If the Work includes a "NOTICE" text file as part of its + distribution, then any Derivative Works that You distribute must + include a readable copy of the attribution notices contained + within such NOTICE file, excluding those notices that do not + pertain to any part of the Derivative Works, in at least one + of the following places: within a NOTICE text file distributed + as part of the Derivative Works; within the Source form or + documentation, if provided along with the Derivative Works; or, + within a display generated by the Derivative Works, if and + wherever such third-party notices normally appear. The contents + of the NOTICE file are for informational purposes only and + do not modify the License. You may add Your own attribution + notices within Derivative Works that You distribute, alongside + or as an addendum to the NOTICE text from the Work, provided + that such additional attribution notices cannot be construed + as modifying the License. + + You may add Your own copyright statement to Your modifications and + may provide additional or different license terms and conditions + for use, reproduction, or distribution of Your modifications, or + for any such Derivative Works as a whole, provided Your use, + reproduction, and distribution of the Work otherwise complies with + the conditions stated in this License. + + 5. Submission of Contributions. Unless You explicitly state otherwise, + any Contribution intentionally submitted for inclusion in the Work + by You to the Licensor shall be under the terms and conditions of + this License, without any additional terms or conditions. + Notwithstanding the above, nothing herein shall supersede or modify + the terms of any separate license agreement you may have executed + with Licensor regarding such Contributions. + + 6. Trademarks. This License does not grant permission to use the trade + names, trademarks, service marks, or product names of the Licensor, + except as required for reasonable and customary use in describing the + origin of the Work and reproducing the content of the NOTICE file. + + 7. Disclaimer of Warranty. Unless required by applicable law or + agreed to in writing, Licensor provides the Work (and each + Contributor provides its Contributions) on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or + implied, including, without limitation, any warranties or conditions + of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A + PARTICULAR PURPOSE. You are solely responsible for determining the + appropriateness of using or redistributing the Work and assume any + risks associated with Your exercise of permissions under this License. + + 8. Limitation of Liability. In no event and under no legal theory, + whether in tort (including negligence), contract, or otherwise, + unless required by applicable law (such as deliberate and grossly + negligent acts) or agreed to in writing, shall any Contributor be + liable to You for damages, including any direct, indirect, special, + incidental, or consequential damages of any character arising as a + result of this License or out of the use or inability to use the + Work (including but not limited to damages for loss of goodwill, + work stoppage, computer failure or malfunction, or any and all + other commercial damages or losses), even if such Contributor + has been advised of the possibility of such damages. + + 9. Accepting Warranty or Additional Liability. While redistributing + the Work or Derivative Works thereof, You may choose to offer, + and charge a fee for, acceptance of support, warranty, indemnity, + or other liability obligations and/or rights consistent with this + License. However, in accepting such obligations, You may act only + on Your own behalf and on Your sole responsibility, not on behalf + of any other Contributor, and only if You agree to indemnify, + defend, and hold each Contributor harmless for any liability + incurred by, or claims asserted against, such Contributor by reason + of your accepting any such warranty or additional liability. + + END OF TERMS AND CONDITIONS + + APPENDIX: How to apply the Apache License to your work. + + To apply the Apache License to your work, attach the following + boilerplate notice, with the fields enclosed by brackets "[]" + replaced with your own identifying information. (Don't include + the brackets!) The text should be enclosed in the appropriate + comment syntax for the file format. We also recommend that a + file or class name and description of purpose be included on the + same "printed page" as the copyright notice for easier + identification within third-party archives. + + Copyright [yyyy] [name of copyright owner] + + Licensed under the Apache License, Version 2.0 (the "License"); + you may not use this file except in compliance with the License. + You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. diff --git a/dolphinscheduler-ui/src/locales/en_US/security.ts b/dolphinscheduler-ui/src/locales/en_US/security.ts index b9bb18966c..8980bc724a 100644 --- a/dolphinscheduler-ui/src/locales/en_US/security.ts +++ b/dolphinscheduler-ui/src/locales/en_US/security.ts @@ -273,6 +273,12 @@ export default { MsgType: 'Msg Type', // eslint-disable-next-line quotes IsAtAll: "{'@'}All", + calledNumber:"Called phone number", + calledShowNumber:"Call display number", + ttsCode:"TTS Code", + address:'Address', + accessKeyId:"AccessKeyId", + accessKeySecret:"AccessKeySecret", annotations: 'Annotations', generatorURL: 'GeneratorURL', }, diff --git a/dolphinscheduler-ui/src/locales/zh_CN/security.ts b/dolphinscheduler-ui/src/locales/zh_CN/security.ts index b16624885b..453d99d7b8 100644 --- a/dolphinscheduler-ui/src/locales/zh_CN/security.ts +++ b/dolphinscheduler-ui/src/locales/zh_CN/security.ts @@ -272,6 +272,12 @@ export default { MsgType: '消息类型', // eslint-disable-next-line quotes IsAtAll: "{'@'}所有人", + calledNumber:"被叫电话号码", + calledShowNumber:"呼叫显示号码", + ttsCode:"语音模板", + address:'访问域名', + accessKeyId:"AccessKeyId", + accessKeySecret:"AccessKeySecret", annotations: '注释', generatorURL: '生成地址', }, diff --git a/tools/dependencies/known-dependencies.txt b/tools/dependencies/known-dependencies.txt index a5d6e59ee1..3e0072a965 100644 --- a/tools/dependencies/known-dependencies.txt +++ b/tools/dependencies/known-dependencies.txt @@ -485,4 +485,18 @@ snowflake-jdbc-3.13.29.jar azure-storage-blob-12.21.0.jar azure-storage-internal-avro-12.6.0.jar vertica-jdbc-12.0.4-0.jar -esdk-obs-java-bundle-3.23.3.jar \ No newline at end of file +esdk-obs-java-bundle-3.23.3.jar +dyvmsapi20170525-2.1.4.jar +alibabacloud-gateway-spi-0.0.1.jar +credentials-java-0.2.2.jar +endpoint-util-0.0.7.jar +openapiutil-0.1.14.jar +tea-1.1.14.jar +tea-openapi-0.2.2.jar +tea-rpc-0.0.11.jar +tea-rpc-util-0.1.3.jar +tea-util-0.2.13.jar +dom4j-2.1.3.jar +jaxb-core-2.3.0.jar +jaxb-impl-2.3.0.jar +