JavaSDK实现数据流分片上传的代码样例
说明 说明：代码中cloneInputStream是复制数据流的实现。import java.io.ByteArrayInputStream;import java.io.ByteArrayOutputStream;import java.io.File;import java.io.FileInputStream;import java.io.IOException;import java.io....
Lindorm助力数禾科技业务系统实现真正的流批一体
客户感言 从我们看中lindorm容量型存储低廉的价格决定采用阿里云Lindorm产品作为我们eventhub流批一体特征平台的底层数据库服务，阿里云Lindorm专家团队和产品团队专程到公司为我们介绍Lindorm产品，特性以及应用场景；在开发过程中当我们...
实现K8s集群应用的限流降级
本教程以在Dubbo应用中配置限流降级规则为例，介绍了如何实现微服务的限流降级。背景信息 EDAS中默认开通AHAS试用版，仅包含入门级防护，您只能为同一个应用类设置2条相同类型的防护规则，如需设置更多规则，请前往AHAS控制台开通专业版。...
实现K8s集群应用的限流降级
本教程以在Dubbo应用中配置限流降级规则为例，介绍了如何实现微服务的限流降级。背景信息 EDAS中默认开通AHAS试用版，仅包含入门级防护，您只能为同一个应用类设置2条相同类型的防护规则，如需设置更多规则，请前往AHAS控制台开通专业版。...
基于事件流实现Kafka消息路由
支持地域 支持在 云消息队列 Kafka 版 之间创建事件流的地域有：华东2（上海）、华北2（北京）、华北3（张家口）、中国香港、德国（法兰克福）、新加坡和日本（东京）。步骤一：在目标端创建事件流 说明 事件流需要在目标端创建，例如如果...
基于Indexing Service实现数据流管理
步骤六：分析日志 在Kibana控制台中，查看基于Indexing Service实现的数据流管理的实时日志流和实时数据指标。步骤一：创建Indexing Service实例 购买内核增强版7.10版本，并开通高级增强特性Indexing Service索引构建服务。操作步骤，请...
基于事件流实现MNS消息路由
在顶部菜单栏，选择创建事件流的地域。在左侧导航栏，单击 事件流。在 事件流 页面，单击 创建事件流。在 创建事件流 面板，设置 任务名称 和 描述，配置以下参数，然后单击 保存。任务创建 在 Source（源）配置向导，选择 数据提供方 为 ...
基于事件流实现RocketMQ消息路由
部分事件$.data.systemProperties.TAGS 任务属性 设置事件流的重试策略及死信队列。更多信息，请参见 重试和死信。返回 事件流 页面，找到创建好的事件流，在其右侧 操作 栏，单击 启用。在 提示 对话框，阅读提示信息，然后单击 确认。...
基于事件流实现RabbitMQ消息路由
部分事件 任务属性 设置事件流的重试策略及死信队列。更多信息，请参见 重试和死信。返回 事件流 页面，找到创建好的事件流，在其右侧 操作 栏，单击 启用。在 提示 对话框，阅读提示信息，然后单击 确认。启用事件流后，会有30秒~60秒的...
基于TairString实现高效限流器
本文介绍的方案也适用于其它需要限速或者限流的场景。抢购限流器 TairString 是Tair新增的数据结构，比原生Redis String功能更加强大，除了比特位（bit）操作外能够覆盖原生Redis String的所有功能。TairString的 EXINCRBY/EXINCRBYFLOAT ...
流计算实现细节
在分布式NoSQL数据库中，对于基于数据捕获变更（CDC）技术的流式接口，该接口是一种持续流的模式，通常不具备灵活的Seek接口，对接Structured Streaming的微批接口有较大的难度。如果在GetOffset阶段进行提前的数据拉取，可以获取到预期的...
通过流引擎实现地理围栏监控
场景说明 通过流引擎的流数据存储和实时计算能力，结合Ganos时空引擎技术，对车辆的点位数据进行地理围栏（指定的路径数据）监控判断。在地理围栏监控场景中，根据业务需求提前将地理围栏数据记录在Lindorm宽表中（图中的route_table表）。...
通过流引擎实现交易数据实时统计
云原生多模数据库 Lindorm 流引擎是面向流式数据处理的引擎，提供了流式数据的存储和轻计算功能。本文介绍使用Lindorm流引擎对交易数据进行实时统计，并将统计结果（即每小时的订单数量和交易金额）存储至Lindorm宽表中。前提条件 已安装...
通过流引擎实现交易数据实时统计
云原生多模数据库 Lindorm 流引擎是面向流式数据处理的引擎，提供了流式数据的存储和计算功能。本文介绍使用Lindorm流引擎对交易数据进行实时统计，并将统计结果（即每小时的订单数量和交易金额）存储至Lindorm宽表中。前提条件 已安装Java...
基于定时SQL对VPC流日志实现细粒度时间窗口分析
本视频介绍如何基于定时SQL对VPC流日志实现细粒度时间窗口分析。
使用集中式工作流实现提交评审与自动化检查
在管控严格的场景下，常常希望每次提交都能够触发变更代码的自动化检查和人工评审，全部通过后才能够真正提交合入目标分支，结合 git-repo 工具，在 ...更多集中式工作流的介绍参见 AGit-Flow 阿里巴巴集中式 Git 工作流，git-repo 工具介绍。
通过推荐过滤功能实现Feed流个性化过滤
本文将向您介绍如何使用推荐过滤功能，实现推荐场景的按需定制，满足用户的特定浏览喜好。一、背景介绍 在某些猜你喜欢场景当中，用户可能会出于需求或自身喜好与经验，只想要看到属于特定品牌等拥有特定属性的物品，此时可以使用推荐过滤...
限流防护
本文介绍限流防护的概念、限流方式以及本地限流和全局限流的实现原理。限流 防护 的概念 限流防护是一种限制发送到服务端的请求数量的机制。它指定客户端在给定时间段内可以向服务端发送的最大请求数，通常表示为一段时间内的请求数，例如...
任务状态轮询
本文介绍了任务状态轮询和 Serverless工作流 实现的具体步骤。简介 在长时间任务的场景中如果任务结束后没有回调机制，开发者通常会采用轮询的方式来判断任务的结束。可靠的轮询实现需要维护状态的持久化以保证即使当前轮询进程失败退出，...
工作流调度固定版本或预留资源函数
本文介绍了工作流调度固定版本或预留资源函数和 Serverless 工作流 实现的具体步骤。简介 在实际生产场景中，任务流所调度的函数因为业务场景变化可能需要频繁变更，您会考虑到如何避免变更带来的非预期行为，控制变更稳定性。在 ...
Serverless工作流
本文介绍了工作流调度固定版本或预留资源函数和 Serverless工作流 实现的具体步骤。简介 在实际生产场景中，任务流所调度的函数因为业务场景变化可能需要频繁变更，我们会考虑到如何避免变更带来的非预期行为，控制变更稳定性。在 ...
Linux RTS SDK集成与实现
本文为您介绍Linux RTS推流SDK的集成和实现方法。操作步骤 下载并解压Linux RTS 推流 SDK。下载地址，请参见 SDK下载。编写以下代码：#include<stdio.h>#include<stdlib.h>#include<string.h>#include<stdarg.h>#include<unistd.h>#include...
使用DataWorks离线调度Designer工作流
PAI Designer支持与DataWorks互通，实现PAI Designer工作流的周期性调度。本文为您介绍如何使用DataWorks实现PAI Designer工作流的离线调度。前提条件 已创建业务流程，具体操作，详情请参见 创建业务流程。重要 创建业务流程时选择的工作...
iOS
通过阅读本文，您可以了解 iOS 输入外部音视频流的方法。输入外部视频流 说明 SDK允许先推流然后开启外部视频输入，但这种情况下，默认开始推流时，先推送出的是本地原始采集源（摄像头或屏幕捕获）的视频数据，直到启用外部输入。1.调用 ...
通过Ingress Controller来实现应用的流量复制
本文介绍如何通过Ingress Controller来实现应用的流量复制。前提条件 已创建两个ACK集群，具体操作，请参见 创建Kubernetes托管版集群。本例中ACK集群一个名为K8s Product Cluster（生产环境集群），另一个名为K8s Stage Cluster（测试环境...
清林云
阿里云 函数计算 承载了清林云的业务API层、常用应用和自定义...清林云当前已经上线的系统依然需要访问外部服务，后续的系统将继续结合 函数计算 和 Serverless工作流，实现自定义应用部署到 函数计算，为自动化流系统带来更多的业务场景。
清林云
阿里云 函数计算 承载了清林云的业务API层、常用应用和自定义...清林云当前已经上线的系统依然需要访问外部服务，后续的系统将继续结合 函数计算 和 Serverless工作流，实现自定义应用部署到 函数计算，为自动化流系统带来更多的业务场景。
工作流流转规则
流转规则是依赖工作流配置实现的，比起之前较为简单的流程设置，我们新增了支持配置「执行条件」和「后续动作」，以实现任务状态流转的权限控制和字段级限制。配置入口：1、项目设置-任务设置-任务工作流设置-工作流配置-列表菜单-配置条件...
创建自定义连接流
本文介绍在AppFlow控制台创建一个自定义连接流的详细操作。步骤一：创建连接流 登录 AppFlow控制台。在左侧导航栏中，单击 连接流，然后单击 创建连接流。在创建链接流页面中，配置连接流内容信息。填写连接流基本信息并单击 下一步。字段...
定时触发工作流
version:v1 type:flow steps:#task step to invoke FC function hello-type:task name:hello resourceArn:acs:fc:services/service-CD946B9A9F36/functions/hello 您可以修改该工作流的定义实现自身的业务逻辑。详情请参见 修改流程。
创建连接流
连接流描述 填写介绍连接流所实现的功能。在新页面中配置触发器信息，然后单击 完成进入下一步。根据需要选择对应的触发器并选择对应的触发事件。（可选）若当前连接器存在入参配置，则需要先完成入参配置。选择执行动作节点。然后单击 ...
使用推荐模板创建连接流
在钉钉群与通义千问进行对话 连接流描述 介绍连接流所实现的功能。将钉钉群聊对话发送给通义千问，并将答复通过钉钉机器人发送回群聊。完成连接流配置，获取钉钉机器人发送消息的Webhook地址，复制并保存该地址。创建钉钉群聊机器人。钉钉...
上传构建产物
前提条件 已完成逻辑流执行代码的开发，前、后端逻辑流的详细操作请分别参见 开发前端逻辑流操作代码 和 开发后端逻辑流操作代码。操作步骤 登录 魔笔。在顶部菜单栏选择 应用管理，在左上角搜索框中搜索目标应用。在目标应用的卡片中单击 ...
自动推拉流功能
本文介绍自动推拉流功能的实现原理和示例代码。实现原理 说明 纯音频场景下，仅支持推拉音频流。音视频场景下，推拉设置的所有音视频流。示例代码 关闭自动推拉流API ARTC SDK提供关闭自动推拉流功能，客户App可以根据业务需求分别控制关闭...
分布式多步骤事务
Serverless 工作流 实现 下文的示例将FC函数编排成一个 Serverless 工作流 流程从而实现了一个可靠的多步骤长流程，该示例分为3步：创建FC函数 创建流程 执行并查看结果 步骤1：创建FC函数 本步骤是模拟场景案例中提示的三个操作即预订火车...
等保合规能力说明
防护配置 17 应对进出网络的数据流实现基于应用协议和应用内容的访问控制。部署云防火墙实现跨VPC数据流的应用协议、内容的访问控制。VPC边界防火墙 安全区域边界>入侵防范 18 应在关键网络节点处检测、防止或限制从外部发起的网络攻击行为...
EMR旧版数据开发迁移公告
在EMR Workflow中导入JSON文件，实现工作流的快速迁移。说明 迁移阶段的导出和导入均不影响原有EMR旧版数据开发中的任务调度。阿里云EMR团队+客户 1小时 三、验证阶段 在EMR Workflow上导入的工作流默认处于下线状态，需要您逐一进行手动...
阿里云流播放器
直播：打开开关，可通过提供直播流实现直播的播放效果，仅在 播放模式 选择 H5 时可配置。音量设置：打开开关，可设置视频静音播放；关闭开关，可自定义设置音量的大小，单位%。仅在 播放模式 选择 H5 时可配置。控制条设置：设置控制条的...
- 产品推荐
- 这些文档可能帮助您