假定某个Flink业务1每秒就会收到1条消息记录，消息记录某个用户的基本信息，包括名字、性别、年龄。另有一个Flink业务2会不定时收到1条消息记录，消息记录该用户的名字、职业信息。 基于某些业务要求，开发的Flink应用程序实现功能：实时的以根据业务2中消息记录的用户名字作为关键字，对两个业务数据进行联合查询。

查看更多 →

使用多线程Producer发送消息 功能介绍 在使用Producer API向安全Topic生产消息基础上，实现了多线程Producer，可启动多个Producer线程，并通过指定相同key值的方式，使每个线程对应向特定Partition发送消息。 下面代码片段在com.huawei

查看更多 →

使用多线程Producer发送消息 功能简介 在使用Producer API向安全Topic生产消息基础上，实现了多线程Producer，可启动多个Producer线程，并通过指定相同key值的方式，使每个线程对应向特定Partition发送消息。 下面代码片段在com.huawei

查看更多 →

主动终止空闲事务 功能介绍 当一个事务长时间空闲且不提交，执行回滚操作时，会对数据库的资源和性能造成损耗。如果有大量的空闲事务长期不执行也不提交、回滚，尤其是在业务高峰期的时候，性能损耗会较为严重。 功能特点 华为云RDS for MySQL针对空闲事务有超时回滚断开连接机制，具有以下特点：

查看更多 →

PC发送的消息手机端搜索不到？ Welink服务端历史记录保存时间为90天，手机端最近会话漫游条数为50条，漫游的消息，只有往上拉消息缓存到本地后才能搜索到。 父主题： 消息

查看更多 →

发送消息（API名称：addMessages） 功能介绍 最常用的消息发送接口 相关接口 接口名称 调用说明 获取Token 调用该接口获取到Token，再调用其他接口时，需要在请求消息头中添加“Authorization”，其值即为Token。 推送消息到消息频道 如只需要推送消息到消息频道可使用该接口

查看更多 →

使用多线程Producer发送消息 功能简介 在使用Producer API向安全Topic生产消息基础上，实现了多线程Producer，可启动多个Producer线程，并通过指定相同key值的方式，使每个线程对应向特定Partition发送消息。 下面代码片段在com.huawei

查看更多 →

使用多线程Producer发送消息 功能简介 在使用Producer API向安全Topic生产消息基础上，实现了多线程Producer，可启动多个Producer线程，并通过指定相同key值的方式，使每个线程对应向特定Partition发送消息。 下面代码片段在com.huawei

查看更多 →

State）实时上报给MQTT broker。 EventBus从MQTT broker收到订阅消息，消息内容包含终端设备的实际状态。 EventBus把终端设备实际状态发送给DeviceTwin，DeviceTwin在边缘节点存储终端设备实际状态。 DeviceTwin同步实际状态给WebSocket客户端EdgeHub。

查看更多 →

State）实时上报给MQTT broker。 EventBus从MQTT broker收到订阅消息，消息内容包含终端设备的实际状态。 EventBus把终端设备实际状态发送给DeviceTwin，DeviceTwin在边缘节点存储终端设备实际状态。 DeviceTwin同步实际状态给WebSocket客户端EdgeHub。

查看更多 →

本文档中提供的API接口均采用短连接（短信接口除外，短信接口可支持长连接。），平台 服务器 作为服务端时会主动拆链，建议SP作为客户端时不要主动拆链，等接收到服务端的FIN, ACK后按照正常四次挥手拆链。 若SP主动拆链，可能造成该链路对应的端口短时间不可用，影响SP发送请求。 父主题： 附录

查看更多 →

主动终止空闲事务 功能介绍 参数介绍 使用示例 父主题： 内核功能

查看更多 →

IDE Daemon发送命令给Host侧执行，比如发送查看Host侧的日期信息的命令。以HwHiAiUser用户登录Host侧服务器。执行命令，查看Host侧的日期信息。IDE-daemon-client --host xx.xx.xx.xx:22118 --hostcmd datexx.xx.xx.xx需要替换为实际的Host的IP地址

查看更多 →

如何实现同时给多个用户发送语音通知？ 调用一次“语音通知API”，被叫号码只能填写一个。若要实现通知多个用户，在最大并发之内可以同时调用多个API，每个API填写不同的被叫号码。 由于运营商管控策略不同，并发数量会存在差异。如果业务量较大，可以联系运营经理进行调整。 父主题： API&代码样例

查看更多 →

ipv4.tcp_wmem 为自动调优定义socket使用的内存。 第一个值是为socket发送缓冲区分配的最少字节数； 第二个值是默认值（该值会被wmem_default 覆盖），缓冲区在系统负载不重的情况下可以增长到这个值； 第三个值是发送缓冲区空间的最大字节数（该值会被wmem_max覆盖）。

查看更多 →

Flume正常连接Kafka后发送消息失败 问题现象 使用 MRS 版本安装集群，主要安装ZooKeeper、Flume、Kafka。 在使用Flume向Kafka发送数据功能时，发现Flume发送数据到Kafka失败。 可能原因 Kafka服务异常。 Flume连接Kafka地址错误，导致发送失败。 F

查看更多 →

def connect(self): self.socket = socket.socket(socket.AF_VSOCK, socket.SOCK_STREAM) self.socket.settimeout(TIMEOUT) print("connecting

查看更多 →

订阅事件 通过订阅事件，用户可以在本地创建socket服务器接收事件消息。 订阅列表展示所有的订阅者信息，包括订阅者名称，订阅时视频源数量，订阅事件数（成功发送并响应），创建时间，描述等信息。支持新建订阅，名称查询，删除，修改等操作。 新建订阅 单击事件订阅，进入事件订阅列表页面。

查看更多 →

设置SMN主题策略，允许DRS发送消息通知 该章节指导用户通过手动设置SMN主题策略的方式，授权DRS服务发送消息通知。 操作步骤 登录管理控制台。 单击管理控制台左上角的，选择区域和项目。 单击“服务列表”，选择“管理与监管 > 消息通知服务”。 进入消息通知服务页面。 在左侧导航栏，选择“主题管理

查看更多 →

IDE Daemon发送命令给Host侧执行，比如发送查看Host侧的日期信息的命令。以HwHiAiUser用户登录Host侧服务器。执行命令，查看Host侧的日期信息。IDE-daemon-client --host xx.xx.xx.xx:22118 --hostcmd datexx.xx.xx.xx需要替换为实际的Host的IP地址

查看更多 →

IDE Daemon发送命令给Device侧执行，比如发送查看Device侧的日期信息的命令。以HwHiAiUser用户登录Host侧服务器。执行命令，查看Device侧的日期信息。IDE-daemon-client --host xx.xx.xx.xx:22118 --cmd datexx.xx.xx.xx需要替换为实际的Host的IP

查看更多 →