数据中台

1、进入数据中台。

数据中台：http://gotest.site/#/rule

2、若数据库没有配置过，则先在数据源中配置数据源。

连接串的格式请与上图中保持一致，若可以添加成功，说明数据库可以连接成功。若添加失败，请检查连接串格式、账号密码是否正确。

3、在SQL规则中添加SQL语句。

在添加规则中定义规则名称，选择添加的数据源，添加SQL语句即可。如在数据库中根据用户id查询用户信息，添加SQL为：select * from zion_user where id in (#{user_id})其中id为自定义查询的参数条件。在SQL语句中要自定义传的参数，用#{key}来表示定义，可定义多个。可在操作-->执行中测试添加的SQL语句，并可以一键拷贝webhook，方便在平台中创建数据库接口用例。

4、在消息队列中添加消息配置。

消息队列主要是用来给消息中间件kafka直接投递消息，为业务准备消息数据。在添加消息配置中定义消息队列名称、选择消息中间件，添加消息配置。配置完成可以在操作-->拷贝链接，一键拷贝消息队列的链接。如：http://10.240.200.46:8082/api/message/kafka/send?id=azzgb&message=&topic=&partition=（id：此消息队列的ID，message：消息体，partition：分区，非必填）。目前支持的消息中间件有：kafka。

5、在GoAPI平台上创建接口。

• 创建数据库接口

数据库接口地址统一为：http://服务器IP/api/rule/call，用例中的id对应的为SQL语句的ID，参数为自定义传的参数。用例创建完成，即可执行用例。

• 创建消息队列接口

数据库接口地址统一为：http://服务器IP/api/message/kafka/send，用例中id对应的消息队列的ID，message为消息体，partition为分区，非必填。用例创建完成，即可根据需要来投递消息。