检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
返回信封前缀 public String getHeader(String name) 通过请求头名称获取对应的请求头值 输入参数 name：请求头名称 返回信息 请求头名称对应的请求头值 public Map<String,String> getHeaders() 获取请求头信息 返回信息
JSONHelper类说明 路径 com.huawei.livedata.lambdaservice.util.JSONHelper 说明 提供Json与Xml、Map之间的相互转换。 方法列表 返回类型 方法和说明 static String json2Xml(String json) json转xml
autoDelete表示是否自动删除，true表示自动删除。自动删除的前提是至少有一个队列或者交换器与该交换器绑定，之后所有与该交换器绑定的队列或者交换器都会解绑。 internal表示是否为内置交换器，true表示是内置的交换器。客户端程序无法直接发送消息到这个交换器，只能通过交换器路由到这个交换器。
Integer 否 设定队列可消费的消息为0时的读取消息等待时间。 如果在等待时间内有新的消息，则立即返回消费结果，如果等待时间内没有新的消息，则到等待时间后返回消费结果。取值范围：1~30s。 默认值：3s max_msgs Integer 否 获取可消费的消息的条数。取值范围：1~10。默认值：10
类型 参数描述 statusCode 必选 Integer 请求处理的结果码。 “0”表示成功。 非“0”表示失败。 statusDesc 可选 String 结果描述。 deviceId 必选 String 平台生成的设备唯一标识，对应设备客户端ID。 示例 { "data":
server-id的值应为大于1的整数，请根据实际规划设置，并且在创建数据集成任务时设置的“Server Id”值需要此处设置的值不同。 expire_logs_days为Binlog日志文件保留时间，超过保留时间的Binlog日志会被自动删除，应保留至少2天的日志文件。 “gtid_mode
username, String password) 访问MQS提供的kafka（开启sasl_ssl）。 输入参数 servers：kafkaConfig中的bootstrap.servers信息 groupId：kafkaConfig中的group.id信息 username：用户名 password：密码
public SoapClient(SoapConfig soapCfg) 构造一个包含SoapConfig配置信息的SOAP请求。 参数：soapCfg表示传入SoapClient的配置信息。 方法列表 返回类型 方法和说明 APIConnectResponse execute() 用于发送SOAP请求
QueueConfig类说明 路径 com.roma.apic.livedata.config.v1.QueueConfig 说明 与RabbitMqConfig和RabbitMqProducer配合使用，对队列进行配置。 构造器详情 public QueueConfig(String
out，由于格式限定，出参的value也需要填写，可填写符合数据类型的任意值，不影响输出结果。 数据API中对存储过程的调用，用String和int来区分字符串和数值，无需加单引号，这一点和SQL要求不一样。 在后端服务的Headers、Parameters或者Body中定义的参数名不能相同，否则将被覆盖。
向指定队列发送消息，可同时发送多条消息。 每次最多发送10条。 每次发送的消息总负载不超过2MB。 endpoint为https://{rest_connect_address}:9292，通过指定实例接口查询rest_connect_address的IP地址。 URI POST /v1/topic/
call_limits Integer 流控时长内分组下的API的总访问次数限制，默认不限，请根据服务的负载能力自行设置 暂不支持 time_interval Integer 流控时长 暂不支持 time_unit String 流控的时间单位 暂不支持 is_default Integer
JSON2XMLHelper类说明 路径 com.huawei.livedata.util.JSON2XMLHelper 说明 提供Json与Xml之间的相互转换。 方法列表 返回类型 方法和说明 static String JSON2XML(String json, boolean returnFormat)
示例代码中的参数说明，可参考获取MQS连接信息获取参数值。 brokers：MQS连接地址和端口。 topics：要生产消息的Topic名称。 user和password：开启SASL_SSL认证时所使用的用户名和密码。 caFile：开启SASL_SSL认证时所使用的客户端证书。
X-Subject-Token的值）。 响应参数 状态码： 200 表4 响应Body参数 参数 参数类型 描述 code String 响应码 start_time Long 开始时间的UTC的时间戳 end_time Long 截止时间的UTC的时间戳 list Array of
Project”对话框，选择“Go”，单击“Next”。 图2 New Project 单击“...”，在弹出的对话框中选择解压后的SDK路径，单击“Finish”。 图3 选择解压后的SDK路径 完成工程创建后，目录结构如下。 图4 新建工程的目录结构 “demo.go”为示例代码，请根据实际情况修改参数后使用。具体代码说明请参考调用API示例。
单击“Next”。 图2 New Project 单击“...”，在弹出的对话框中选择解压后的SDK路径，单击“Finish”。 图3 选择解压后的SDK路径 完成工程创建后，目录结构如下。 图4 新建工程的目录结构 “signer.php”为示例代码，请根据实际情况修改参数后使用。具体代码说明请参考调用API示例。
打开工程 打开Android Studio，选择“File > Open”。 在弹出的对话框中选择解压后的SDK路径。 打开工程后，目录结构如下。 图1 工程目录结构 调用API示例 在Android工程中的“app/libs”目录下，加入SDK所需jar包。其中jar包必须包括： java-sdk-core-x
构造器详情 public KafkaProducer(Map configs) 构造一个Kafka消息生产者 参数：configs表示Kafka的配置信息 方法列表 返回类型 方法和说明 org.apache.kafka.clients.producer.RecordMetadata produce(String
prepareValue) 执行SQL语句、存储过程或NOSQL查询语句 输入参数 prepareValue：仅在SQL语句中生效，用于替换SQL语句中的"?"参数，可以防止SQL注入。 返回信息 返回语句执行结果 父主题： 自定义后端开发（函数后端）
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
