第六章 Ambari二次开发之自定义Flink服务 -- metainfo.xml配置文件详解

1、公共框架部分

• 注意：需要在 内来描述自定义服务相关信息

<metainfo>
    <schemaVersion>2.0schemaVersion>
    <services>
		自定义服务相关信息<-->
    services>
metainfo>
1
2
3
4
5
6
7

2、service - 描述服务

Ⅰ、name: 服务名，必须唯一，建议大写<-->
<name>FLINKname>

Ⅱ、displayName: 服务在 web UI 上的显示名<-->
<displayName>FlinkdisplayName>

Ⅲ、comment: 服务的描述信息<-->
<comment>Apache Flink is a streaming dataflow engine that provides data distribution, communication, and fault tolerance for distributed computations over data streams.comment>

Ⅳ、version: 服务版本, 用 name 和 version 唯一标记一个服务<-->
<version>1.14.5version>

Ⅴ、components: 服务中包含的组件<-->
<components>
    <component>
        <name>FLINK_MASTERname>
        <displayName>FlinkdisplayName>
        <category>MASTERcategory>
        <cardinality>1cardinality>
        <commandScript>
            <script>scripts/flink.pyscript>
            <scriptType>PYTHONscriptType>
            <timeout>10000timeout>
        commandScript>
    component>
components>

Ⅵ、osSpecifics: 服务会根据操作系统的差异来选择不同的 rpm 包<-->
<osSpecifics>
    <osSpecific>
        <osFamily>redhat7,redhat6osFamily>
        <packages>
            <package><name>gitname>package>
            <package><name>java-1.7.0-openjdk-develname>package>
            <package><name>apache-maven-3.2*name>package>
        packages>
    osSpecific>
osSpecifics>

Ⅶ、configuration-dependencie: 服务依赖的 xml 文件<-->
<configuration-dependencies>
    <config-type>flink-ambari-configconfig-type>
configuration-dependencies>

Ⅷ、restartRequiredAfterChange: 服务更改后是否强制重启<-->
<restartRequiredAfterChange>falserestartRequiredAfterChange>

Ⅸ、requiredServices: 集群上强制依赖的其他服务<-->
<requiredServices>
    <service>YARNservice>
requiredServices>
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

• 参数说明如下

• 文件结果展示

3、service/components - 一个服务中服务包含的组件

components: 服务中包含的组件<-->
<components>
    <component>
        Ⅰ、name: 组件名称<-->
        <name>FLINK_MASTERname>
        
        Ⅱ、displayName: 组件显示名称<-->
        <displayName>FlinkdisplayName>
        
        Ⅲ、category: 组件角色<-->
        <category>MASTERcategory>
        
        Ⅳ、cardinality: 安装机器数<-->
        <cardinality>1cardinality>
        
        Ⅴ、commandScript: 调用python脚本执行命令<-->
        <commandScript>
            <script>scripts/flink.pyscript>
            <scriptType>PYTHONscriptType>
            <timeout>10000timeout>
        commandScript>
    component>
components>
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

• 参数说明如下

• 前端页面展示：每个标签对应一个Started

4、service/osSpecifics - 操作系统特定包名 rpm 包

osSpecifics: 服务会根据操作系统的差异来选择不同的 rpm 包<-->
<osSpecifics>
    <osSpecific>
        Ⅰ、osFamily: rpm 包适用的操作系统<-->
        <osFamily>redhat7,redhat6osFamily>
        Ⅱ、/package/name: 部署服务需要的包名<-->
        <packages>
            <package><name>gitname>package>
            <package><name>java-1.7.0-openjdk-develname>package>
            <package><name>apache-maven-3.2*name>package>
        packages>
    osSpecific>
osSpecifics>
1
2
3
4
5
6
7
8
9
10
11
12
13

• 参数说明如下

5、service/configuration-dependencies – 指向configuration中的xml文件配置

• 注意事项：配置文件可以有多个

Ⅶ、configuration-dependencie: 服务依赖的 xml 文件<-->
<configuration-dependencies>
    <config-type>flink-ambari-configconfig-type>
configuration-dependencies>
1
2
3
4

• 具体参数如下

• 前端展示

• 注意事项：放置位置
  • ①放在component下：重启单个Componet组件
  • ②放在整个文件下：重启整个服务

6、service/component/commandScript - 标准化命令，用来指定服务的主程序

实现自定义命令的脚本<-->
<commandScript>
    Ⅰ、script: 脚本路径<-->
    <script>scripts/flink.pyscript>
    
    Ⅱ、scriptType: 脚本类型<-->
    <scriptType>PYTHONscriptType>
    
    Ⅲ、timeout: 自定义命令超时时间<-->
    <timeout>10000timeout>
commandScript>
1
2
3
4
5
6
7
8
9
10
11

• 具体参数如下

• 服务后台主程序

7、扩展一：service/component/customCommands - 自定义组件服务命令

• 效果：可配置相关Python脚本，实现服务组件的安装、启动、重启等相关功能。

<customCommands>
    <customCommand>
        <name>CLEANname>
        <commandScript>
            <script>scripts/flink_server.pyscript>
            <scriptType>PYTHONscriptType>
            <timeout>600timeout>
        commandScript>
    customCommand>
customCommands>
1
2
3
4
5
6
7
8
9
10

• 参数说明

8、扩展二：service/commandScript - 运行服务检查

• 效果：可配置相关Python脚本，实现服务组件的心跳监控功能

<commandScript>
    <script>scripts/service_check.pyscript>
    <scriptType>PYTHONscriptType>
    <timeout>300timeout>
commandScript>
1
2
3
4
5

• 参数说明

9、扩展三：service/themes-dir - 创建自定义主题

• 注意实现：需要指定自定义主题JSON文件路径

<themes>
    <theme>
        <fileName>credentials.jsonfileName>
        <default>truedefault>
    theme>
themes>
1
2
3
4
5
6

• 参数说明

10、扩展四：service/quickLinksConfigurations-dir - 创建quiks链接

• 注意事项：需要制定qucklink.json文件

<quickLinksConfigurations>
    <quickLinksConfiguration>
        <fileName>quicklinks.jsonfileName>
        <default>truedefault>
    quickLinksConfiguration>
quickLinksConfigurations>
1
2
3
4
5
6

• 参数说明