检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
在线安装DIS Logstash Plugin 安装DIS Logstash Plugin有在线和离线安装两种方式: 在线安装无需下载插件包,直接连接公网即可安装。 前提条件 已安装PuTTY工具。 安装logstash-input-dis 使用PuTTY工具(或其他终端工具)远程登录Logstash服务器。
Logstash Plugin上传与下载数据 DIS Logstash Plugin概述 安装DIS Logstash Plugin前准备 在线安装DIS Logstash Plugin 离线安装DIS Logstash Plugin 配置DIS Logstash Plugin 验证DIS
离线安装DIS Logstash Plugin 安装DIS Logstash Plugin有在线和离线安装两种方式: 离线安装需要获取插件包并执行安装脚本。 前提条件 已安装PuTTY工具。 操作步骤 使用PuTTY工具(或其他终端工具)远程登录Logstash服务器。 进入到Logstash的安装目录。
转储任务创建时间。 last_transfer_timestamp Long 转储任务最近一次转储时间。 请求示例 查询转储任务列表 GET https://{Endpoint}/v2/{project_id}/streams/{stream_name}/transfer-tasks 响应示例
error_code String 错误码。 error_message String 错误消息。 请求示例 上传数据 POST https://{Endpoint}/v2/{project_id}/records { "stream_name" : "newstream"
Id和Secret Access Key)。 每个用户仅允许新增两个访问密钥。 为保证访问密钥的安全,访问密钥仅在初次生成时自动下载,后续不可再次通过管理控制台界面获取。请在生成后妥善保管。 使用AK/SK认证时,您可以基于签名算法使用AK/SK对请求进行签名,也可以使用专门的签名SDK
用户消费程序端的元数据信息。 元数据信息的最大长度为1000个字符。 最大长度:1000 响应参数 无 请求示例 提交Checkpoint POST https://{Endpoint}/v2/{project_id}/checkpoints { "stream_name" : "newstream"
timestamp_type String 时间戳类型。 CreateTime:创建时间。 缺省值:CreateTime 请求示例 下载数据 GET https://{Endpoint}/v2/{project_id}/records 响应示例 状态码: 200 正常返回 { "records"
序列号,用来记录该通道的消费检查点。 metadata String 用户消费程序端的元数据信息。 请求示例 查询Checkpoint详情 GET https://{Endpoint}/v2/{project_id}/checkpoints 响应示例 状态码: 200 正常返回 { "sequence_number"
effect String 授权影响类型。 accept:允许该授权操作。 枚举值: accept 请求示例 查询权限策略列表 GET https://{Endpoint}/v2/{project_id}/streams/{stream_name}/policies 响应示例 状态码:
commit_checkpoint_stream_names Array of strings 关联通道列表。 请求示例 查询App详情 GET https://{Endpoint}/v2/{project_id}/apps/{app_name} 响应示例 状态码: 200 正常返回 {
参数类型 描述 timestamp Long 时间戳。 value Long 时间戳对应的监控值。 请求示例 查询通道监控数据 GET https://{Endpoint}/v2/{project_id}/streams/{stream_name}/metrics 响应示例 无 SDK代码示例
(Access Key ID/Secret Access Key)是用户调用接口的访问密钥。由用户在Iam中创建,可在“我的凭证 > 访问密钥”页面下载生成。 获取项目ID 项目ID表示租户的资源。用户可在“我的凭证 > > API凭证”页面下查看项目列表中不同Region对应的项目ID。 获取region和endpoint
(Access Key ID/Secret Access Key)是用户调用接口的访问密钥。由用户在Iam中创建,可在“我的凭证 > 访问密钥”页面下载生成。 获取项目ID 项目ID表示租户的资源。用户可在“我的凭证 > > API凭证”页面下查看项目列表中不同Region对应的项目ID。 获取region和endpoint
数据游标。 取值范围:1~512个字符。 说明: 数据游标有效期为5分钟。 最小长度:1 最大长度:512 请求示例 获取数据游标 GET https://{Endpoint}/v2/{project_id}/cursors 响应示例 状态码: 200 正常返回 { "partition_cursor"
AK/SK (Access Key ID/Secret Access Key)是用户调用接口的访问密钥。由用户在Iam中创建,可在页面下载生成。 检查项目ID ProjectID表示租户的资源,每个Region都有一个唯一的项目ID。可在“我的凭证 > API凭证”页面查看不同Region对应的项目ID值。
Id和Secret Access Key)。 每个用户仅允许新增两个访问密钥。 为保证访问密钥的安全,访问密钥仅在初次生成时自动下载,后续不可再次通过管理控制台界面获取。请在生成后妥善保管。 检查项目ID 项目ID表示租户的资源,账号ID对应当前账号,IAM用户ID对应当前用户。用户可在
d value String 值。 对应的是企业项目ID,需要在企业管理页面获取。 36位UUID。 请求示例 查看通道详情 GET https://{Endpoint}/v2/{project_id}/streams/{stream_name} 响应示例 状态码: 200 正常返回
应用名称由字母、数字、下划线和中划线组成,长度为1~200个字符。 最小长度:1 最大长度:200 响应参数 无 请求示例 创建消费App POST https://{Endpoint}/v2/{project_id}/apps { "app_name" : "newapp" } 响应示例
通过调用IAM服务获取用户Token接口获取(响应消息头中X-Subject-Token的值)。 响应参数 无 请求示例 删除指定通道 DELETE https://{Endpoint}/v2/{project_id}/streams/{stream_name} 响应示例 无 SDK代码示例 SDK代码示例如下。