-
Kafka - 应用与数据集成平台 ROMA Connect
创建Kafka连接 登录新版ROMA Connect控制台。 在左侧导航栏选择“连接器”,在连接器页面单击“新建连接”。 选择“Kafka”连接器。 在弹窗中配置连接器信息,完成后单击“确定”。 参数 说明 连接名称 填写连接器实例名称。 Brokers地址 填写Kafka的Brokers地址。
-
附录:如何提高消息处理效率 - 应用与数据集成平台 ROMA Connect
Connect作为消息管理系统,查看队列的消息内容对于定位问题与调试服务是至关重要的。 当消息的生产和消费过程中遇到疑难问题时,通过创建不同消费组可以帮助定位分析问题或调试服务对接。用户可以创建一个新的消费组,对主题中的消息进行消费并分析消费过程,这样不会影响其他服务对消息的处理。 父主题: MQS连接开发(开源客户端)
-
创建负载通道(可选) - 应用与数据集成平台 ROMA Connect
填写负载通道的服务器访问端口号。 分发算法 选择后端服务请求的分发算法,负载通道通过分发算法确定请求被发送到哪台服务器上。 配置通道内服务器。 选择“服务器添加方式”,服务器添加方式在负载通道创建后将不能修改。 选择云服务器:通过选择云服务器的方式添加负载通道服务器。Site实例中,不支持“选择云服务器”方式。
-
自定义数据源开发示例(实时任务) - 应用与数据集成平台 ROMA Connect
通过Linux或Windows将生成的jar包RealtimeConnector-1.0-SNAPSHOT.jar上传到装有JDK环境的用户服务器上,执行以下命令运行即可。 # java -jar RealtimeConnector-1.0-SNAPSHOT.jar & 以MQS数据源作为源端
-
创建负载通道(可选) - 应用与数据集成平台 ROMA Connect
填写负载通道的服务器访问端口号。 分发算法 选择后端服务请求的分发算法,负载通道通过分发算法确定请求被发送到哪台服务器上。 后端服务器类型 选择负载通道中的服务器成员类型。成员类型在负载通道创建后将不能修改。 云服务器:通过选择云服务器的方式添加负载通道成员。 服务器地址:通过填写服务器IP地址的方式添加负载通道成员。
-
添加证书时系统提示证书链不完整 - 应用与数据集成平台 ROMA Connect
通过记事本打开所有*.PEM格式的证书文件。 将服务器证书放在首位,再放置证书链。 一般情况下,中级机构在颁发证书的时候会有对应说明,请注意查阅相关规则。通用的规则如下: 证书之间没有空行。 证书链的格式如下: -----BEGIN CERTIFICATE----- -----END
-
部署Filebeat和ELK - 应用与数据集成平台 ROMA Connect
如果授权错误,则执行以下命令删除授权,并重新为该用户授权。 bin/elasticsearch-users roles -r auth_name username 其中,auth_name为查询到授权错误的权限名称。 执行以下命令退出ElasticSearch容器。 exit 执行以下命令
-
自定义数据源开发示例(定时任务) - 应用与数据集成平台 ROMA Connect
读写参数定义中,填写自定义插件执行读写操作时需要获取的额外信息,如要读写的表名、可以进行增量读取的时间戳字段列名等。 图2 连接器配置2 发布连接器 连接器创建完成后,单击发布,可以发布连接器的实例。 连接器和连接器实例的关系,类似编程中的类和类对象实例。 连接器定义了针对某种数据源的规范,连接器实例则对
-
修改后端实例 - 应用与数据集成平台 ROMA Connect
开启后对应后端服务为备用节点,仅当非备用节点全部故障时工作。 实例需要升级到对应版本才支持此功能,若不支持请联系技术支持。 缺省值:false member_group_name 否 String 后端服务器组名称。为后端服务地址选择服务器组,便于统一修改对应服务器组的后端地址。
-
构造请求 - 应用与数据集成平台 ROMA Connect
HTTP请求方法(也称为操作或动词),它告诉服务你正在请求什么类型的操作。 表2 HTTP方法 方法 说明 GET 请求服务器返回指定资源。 PUT 请求服务器更新指定资源。 POST 请求服务器新增资源或执行特殊操作。 DELETE 请求服务器删除指定资源,如删除对象等。 HEAD 请求服务器资源头部。 PATCH
-
APIC是否支持多后端节点方案? - 应用与数据集成平台 ROMA Connect
APIC是否支持多后端节点方案? 通过负载通道支持多后端节点。一个负载通道中可以添加多个弹性云服务器。 父主题: 服务集成
-
准备Docker环境和镜像 - 应用与数据集成平台 ROMA Connect
Engine和安装Docker Compose为ELK所部署的服务器安装Docker和Docker Compose。 参考安装Docker Compose为APIC的SHUBAO组件所在节点安装Docker Compose。 在本地PC上,切换root用户,并执行以下命令拉取Docker镜像。 docker
-
使用Kibana查看日志 - 应用与数据集成平台 ROMA Connect
Discover”。 在页面中单击“Create data view”,创建数据视图。 在创建数据视图页面中,配置视图信息,完成后单击“Save data view to Kibana”保存视图。 Name:数据视图名称,自定义。 Index pattern:使用通配符形式匹配多个日志索引
-
如何调用API - 应用与数据集成平台 ROMA Connect
如何调用API 构造请求 认证鉴权 返回结果
-
API指标统计值查询-最近一段时间 - 应用与数据集成平台 ROMA Connect
根据API的ID和最近的一段时间查询API被调用的次数,统计周期为1分钟。查询范围一小时以内,一分钟一个样本,其样本值为一分钟内的累计值。 为了安全起见,在服务器上使用curl命令调用接口查询信息后,需要清理历史操作记录,包括但不限于“~/.bash_history”、“/var/log/messages”(如有)。
-
准备资源 - 应用与数据集成平台 ROMA Connect
--downloadonly 从机器上导出上面下载的RPM包,再通过内网导入到所有边缘节点上进行安装。 重新创建ROMA Site实例 如果您是在已创建过ROMA Site实例,且实例已删除的虚拟机上重新创建ROMA Site实例,则需执行以下操作。 以root用户分别登录所有虚拟机。 执行以下命令清除已删除实例遗留的数据。
-
认证鉴权 - 应用与数据集成平台 ROMA Connect
Key):与访问密钥ID结合使用的密钥,对请求进行加密签名,可标识发送方,并防止请求被修改。 使用AK/SK认证时,您可以基于签名算法使用AK/SK对请求进行签名,也可以使用专门的签名SDK对请求进行签名。详细的签名方法和SDK使用方法请参见API签名指南。 签名SDK只提供签名功能,与服务提供的SDK不同,使用时请注意。
-
服务集成 - 应用与数据集成平台 ROMA Connect
服务集成 APIC是否支持多后端节点方案? 使用iOS系统时,如何进行APP认证? 怎样保证API对应的后端服务器的安全? 对API的修改是否需要重新发布? API发布到RELEASE环境可以正常访问,发布到非RELEASE环境无法访问? API发布到不同环境后,会调用不同的后端服务吗?
-
创建API - 应用与数据集成平台 ROMA Connect
成应用。 类型 选择API的上架类型。 公开:表示API可以上架云市场。 私有:表示API所在分组上架云市场时,该API不会上架。 安全认证 选择API的安全认证方式,推荐使用APP认证方式。 APP认证:表示由ROMA Connect对API请求进行安全认证。用户调用API时,
-
配置业务术语 - 应用与数据集成平台 ROMA Connect
可以同步第三方数据标准,仅支持上架和下架功能,不支持修改。在模型目录中编辑模型实例时,可以绑定数据标准。上架之后,数据标准在模型地图中可以进行检索。在模型术语详情中,您可以将模型术语和模型实例进行绑定。在模型地图进行模型检索时,可以通过模型术语来进行过滤。 前提条件 已完成采集技术模型和录入业务模型。