千人千面，个性化定制，源站计算成本高： 企业网站为了提升用户转化率，往往需要在源站服务器根据用户历史数据，计算出千人千面的个性化推荐结果。一方面给源站服务器带来了较大的计算成本，另一方面由于中心化部署带来的网络时延，企业更加容易错失商机。
在日常的开发过程中，有一个很重要的任务是能够通过Rust语言实现K8s中的各种生态组件，在这个过程中，既需要能过够了解K8S的工作原理也需要能够知道rust的语言特性。因此，在这个过程中有很多值得探讨的知识点。
在实现一个多线程的 Web 服务器时，我们会遇到一个问题：如何在创建线程之后让它们在没有任务时保持等待状态，并且在任务到来时可以立即执行。这是一个典型的线程池设计问题。在 Rust 中，我们需要通过自定义设计来实现这个功能，因为标准库中的 **thread::spawn 并不直接支持这种用法。
在并发编程中，线程同步是一个重要的概念，用于确保多个线程在访问共享资源时能够正确地协调。Tokio 是一个强大的异步运行时库，为 Rust 提供了多种线程同步机制。以下是一些常见的同步机制：
近日，国际数据公司（IDC）发布《协同大模型防火墙能力的中国WAAP厂商技术能力评估，2025》报告，围绕Web安全、Bot管理、威胁情报等核心现代应用防护需求，对厂商的产品技术与服务能力展开全面考察。天翼云云WAF产品在评估中表现突出，“Web安全、Bot管理、威胁情报、应用层DDoS攻击防御、行业应用”五大核心维度获得满分...
在这里，我们需要搭建一个K8S环境用于提供flink任务的运行时环境。在这里推荐使用kubeadm或者一些脚本工具搭建，可参考本自动k8s脚本工具。具体过程在这里省略，可以参考上述链接中的文档进行操作。
Apache Flink 是一个流处理引擎，具有高效的流处理和批处理能力，以及良好的可伸缩性和容错性。Kubernetes（简称 K8s）是一种容器编排系统，用于自动化容器部署、扩展和管理。将 Flink 部署在 K8s 上可以充分利用 Kubernetes 的优势，实现流处理的高可用、高性能和高弹性。
对于流式数据，时间是一个重要的标识。在flink的事件时间语义下，我们不依赖系统时间，而是基于数据自带的时间戳去定义了一个时钟，用来表示当前时间的进展。于是每个并行子任务都会有一个自己的逻辑时钟，它的前进是靠数据的时间戳来驱动的。
随着数字化转型进程不断深入，云计算已成为推动千行百业智能化升级的核心引擎。弹性计算服务凭借其灵活扩展、高可用和高性能等特点，正持续为企业提供关键基础设施支持。面对日益复杂的业务场景与持续增长的计算需求，天翼云始终致力于通过持续创新和技术升级，推动弹性计算服务不断演进。
近日，2025年中国国际服务贸易交易会（简称服贸会）在北京隆重举行。本届服贸会以“数智领航，服贸焕新”作为年度主题，顺应服务贸易数字化、智能化、绿色化趋势，聚焦人工智能、医疗健康、智慧物流、商旅文体健融合发展等专业领域，展示多个国家和地区的创新发展成果。天翼云携多款创新成果精彩亮相，全面展现在智能算力...
flinkCDC功能是面向binlog进行同步、对数据的增删改进行同步的工具，能够实现对数据的动态监听。目前其实现原理主要为监听数据源的binlog对数据的变化有所感知。
Flink是一个大数据流处理引擎，可以为不同行业提供实时大数据处理解决方案。随着Flink的快速发展和改进，世界各地的许多公司现在都能看到它的存在。目前，北美、欧洲和金砖国家都是全球Flink应用的热门地区。当然，Flink在中国的知名度特别高，部分原因是一些互联网大厂的贡献和引领效应，也符合中国的反应与场景密切相...
近日，由天翼云科技有限公司基础架构事业部（操作系统技术部）高性能网络研发团队撰写的论文《APSCC: Adaptive Congestion Control for Packet-Sprayed RDMA Networks in AI Clusters》被2025年第27届IEEE国际高性能计算与通信会议（HPCC）高分录用。这标志着天翼云在高性能网络与人工智能集群通信领域的核心技术已达到...
本文分享自天翼云开发者社区《Flink Parallelism、Flink Slot的关系》，作者：王**帅1、Parallelism（并行度）的概念parallelism 在 Flink 中表示每个算子的并行度。举两个例子（1）比如 kafka 某个 topic 数据量太大，设置了10个分区，但 source 端的算子并行度却为1，只有一个 subTask 去同时消费10个分区，明显很慢。...
dataStreamApi是一切的基础，处于调度flink程序处理任务的起点。Flink 有非常灵活的分层 API 设计，其中的核心层就是 DataStream/DataSet API。由于新版本已经实现了流批一体，DataSet API 将被弃用，官方推荐统一使用 DataStream API 处理流数据和批数据。因此在这里我们统称为DataStream Api。首先在这里我们需要新建...
近日，以“国云聚智 AI甬动”为主题的天翼云中国行·宁波站暨2025浙江电信AI+产业融合创新主题活动在宁波成功举办。作为第十五届智慧城市与智能经济博览会的重要组成部分，本次活动邀请到宁波市人民政府副市长金珊，宁波市人民政府副秘书长虞礼勇，宁波市通信管理局局长杨碧慧，宁波市经济和信息化局副局长汪辉，宁波市发展...
1、生成证书如我输入命令如下：依次是 密码—重输密码—名与姓—组织单位—组织名—城市—省份—国家两位代码—密码—重输密码，后面告警不用管，此步骤要注意的是，名与姓这一项必须输入域名，如 “localhost”,切记不可以随意写，我曾尝试使用其他字符串，在后面客户端生成证书认证的时候一直有问题。
在 SQL 中，我们可以把一些数据的转换操作包装起来，嵌入到 SQL 查询中统一调用，这就是“函数”（functions）。Flink 的 Table API 和 SQL 同样提供了函数的功能。两者在调用时略有不同：Table API 中的函数是通过数据对象的方法调用来实现的；而 SQL 则是直接引用函数名称，传入数据作为参数。例如，要把一个字符串 str ...
本文分享自天翼云开发者社区《分布式系统-秒杀》，作者：胡**冲链接暴露打开谷歌的开发者模式，查看网页代码，请求时就会有接口地址按钮置灰在开放前按钮一直置灰，URL 不会暴露，定期更换地址URL 动态化 {代码...} 服务单一职责单独建立一个数据库，订单服务对应订单库，秒杀是秒杀库。单一职责的好处就是就算秒杀没抗...
近日，由天翼云公有云事业部联合基础架构事业部所撰写的论文《CTCCL:Cost-Efficient Joint Device-Network Load Balancing for LLM Training inRoCE-based Intelligent Computing Network》被第39届ACM International Conference on Supercomputing 2025 (简称ICS)收录。这一成果不仅标志着天翼云在智算网络领域的技术突...
