在AppFlow中，各节点都存在输入和输出参数，下游节点的输入参数往往需要引用上游节点的输出参数，在AppFlow中利用参数引用可实现此功能需求。本文介绍在AppFlow中插入变量实现参数的引用。使用方法 创建数据流时，当选择的连接器包含入参...
pragma mark-AUIVideoFunctionListView.h/添加数据源/sources是数组，装载AUIVideoInfo类型的数据，具体类型可参考AUIVideoListCommon/Models/AUIVideoInfo.h文件 NSArray*>*sources=xxxx;[mVideoFunctionListView loadSources:sources];...
通过SQL查询数据 通过SQL查询数组类型时需要使用 ARRAY_EXTRACT(col_name)函数实现，其中 col_name 为数组列名。该函数支持与运算符组合使用作为查询条件，例如 ARRAY_EXTRACT(col_long)=1。重要 通过SQL查询数组类型时，不能直接使用数组...
目前已支持返回数组和地理位置的列，但是返回的字段值会被格式化，可能和写入数据表的值不一致。例如对于数组类型，写入数据表的值为"[1,2,3,4]"，则通过ParallelScan接口导出的值为"[1,2,3,4]；对于地理位置类型，写入数据表的值为 10,50...
param b 二进制数组*@return 十六进制字符串*/private String byte2hex(byte[]b){ StringBuffer sb=new StringBuffer();for(int n=0;b!null&n;n+){ String stmp=Integer.toHexString(b[n]&0XFF);if(stmp.length()=1){ sb.append('0');} sb....
blob：二进制大对象（binary large object）是任意字节数组的术语简称。这个类型在存储媒体或者其他二进制数据类型时很有用，Cassandra并不会检查其中存储的二进制数据是否有效。Cassandra中二进制大对象是以十六进制存储的，如果想将任意...
ECI支持搭配使用阿里云弹性伸缩（ESS）服务，实现根据实时负载动态增加或者减少ECI实例，从而提升资源利用率和系统可用性，降低使用成本。本文以Spring Boot容器应用为例，演示如何配置负载均衡和弹性伸缩，实现根据实时负载自动扩缩容ECI...
EAS 支持通过Python官方SDK或自行实现调用逻辑的方式对服务进行VPC高速直连调用。本文详细介绍这两种调用方式的实现方法。调用原理 VPC高速直连调用、公网调用及VPC地址调用的链路如下图所示。开启服务运行所在资源组的VPC高速直连功能后，...
DML语句 INSERT INTO `sink` SELECT `a`,b,c.e[1],-Flink从1开始遍历数组，本示例为获取数组中的元素1。如果获取整个数组，则去掉[1]。c.f.m FROM `kafka_table`;测试结果 Flink和Kafka网络连通，但Flink无法消费或者写入数据？问题原因 ...
解决方法：所有Key都应该由KEYS数组来传递，例如 EVAL"return redis.call('mget',KEYS[1],KEYS[2])"2 foo {foo}bar，不能使用Lua变量替换KEYS，更多信息请参见 集群中Lua脚本的限制。EXECABORT Transaction discarded because of previous ...
解决方法：所有Key都应该由KEYS数组来传递，例如 EVAL"return redis.call('mget',KEYS[1],KEYS[2])"2 foo {foo}bar，不能使用Lua变量替换KEYS，更多信息请参见 集群中Lua脚本的限制。EXECABORT Transaction discarded because of previous ...
本文介绍Java SDK的版本信息，包含使用限制、下载链接、发布时间、更新点等，以便您按需获取适用的Java SDK收发消息。使用限制 JDK 1.8适用于所有Java ons-client版本，JDK 1.6仅支持ons-client v1.8.4.Final及之前的版本使用。为避免升级...
如果您在使用 Flink、Spark、Storm 等大数据计算引擎时，需要将日志进行压缩、批量 上传日志到日志服务、减少网络传输资源的占用，API或者SDK往往无法满足大数据场景对数据写入能力的要求，您可以使用Aliyun Log Java Producer，便捷高效地...
Hadoop 3.3：Java 8和Java 11 Hadoop 3.0.x~3.2.x：Java 8 Hadoop 2.7.x~2.10.x：Java 7和Java 8 本文使用的版本为Hadoop 3.2.4和Java 8，如您使用其他版本，请参考Hadoop官网指南。更多信息，请参见 Hadoop Java Versions。步骤一：安装...
实现原理是当消费组下的正常消费数据的客户端发生故障后，其他的SDK客户端将随机且自动地分配到partition 0，继续消费。设置Java文件代码中的必填参数。表 1.必填参数说明 参数 说明 获取方式 brokerUrl 数据订阅通道的网络地址及端口号...
日志服务Java SDK：使用GetLogs接口查询日志 使用Java SDK管理日志库Logstore 通过消费组消费数据 使用Aliyun Log Java Producer写入日志数据 日志服务Python SDK：使用GetLogs接口查询日志 使用Python SDK管理日志库Logstore 使用...
在完成数据订阅通道的配置（创建好订阅任务和消费组）后，您可以自行编写SDK示例代码或使用DTS提供的SDK示例代码来订阅数据变更信息，本文介绍示例代码的使用方法。重要 本操作为Java语言的SDK客户端示例，Python和Go语言的示例代码，请...
管理灰度规则（Java）灰度发布应用 调整实例配额 新增 支持动态调整自动弹性与手动扩容的最大实例数。配置弹性伸缩策略 基础监控指标完善 优化 基础监控指标完善，新增支持网络、磁盘监控，历史应用需重启查看。基础监控 体验优化 优化 ...
模型 选中 使用模型：把模型管理的服务地址透传到算法启动参数，节点内部实现时即可调用对应的Java或Python版本的模型管理 SDK 来操作模型列表中的模型。代码包 开发语言 当前支持 Java 和 Python 两种语言，支持的版本如下：Java：Java 7 ...
当日常业务中有非主键列查询、多列组合查询、模糊查询等多维查询需求以及求最值、统计行数、数据分组等数据分析需求时，您可以将这些属性作为多元索引中的字段并使用多元索引查询与分析数据。更多信息，请参见 多元索引。说明 除了SQl引擎...
1 功能简介 SFA智能营销引擎实现营销流程可视化自动化，圈人、邮件/短信/微信模板消息触达、优惠等营销活动自由拼装组合，可以满足绝大多数的营销活动场景，帮助商家实现科学、简易、智能的数据化营销。2 营销活动 2.1 活动规划 2.1.1 活动...
对服务端进行业务开发，实现接收设备数据和下发控制指令。本文以Java脚本为例，演示接收设备数据和下发控制指令。准备开发环境 本文使用Java开发环境如下：操作系统：Windows 10 64位 JDK版本：JDK8 集成开发环境：IntelliJ IDEA社区版 ...
示例使用Java开发语言，推荐使用Apache Qpid JMS客户端，实现AMQP客户端的接入。您可访问 Qpid JMS 0.57.0，查看Qpid JMS客户端使用说明。示例使用的开发环境如下：操作系统：Windows 10 64位 JDK版本：JDK8 集成开发环境：IntelliJ IDEA...
SAE 弹性伸缩可以实现在秒级流量波峰到来时应用实例自动扩容，波峰结束后自动缩容，保障应用平稳运行，具有高可靠性、免运维、低成本的特点。以应对电商大促为例，您可以通过部署应用、配置弹性规则、实时监控并调整策略，以及执行后续的运...
步骤五：管理防护策略组 为满足不同业务情况下的安全需求，应用防护功能对攻击检测规则的能力进行分级，提供了防护策略组：默认宽松规则组（业务优先）、默认标准规则组（正常运营）和默认严格规则组（防护优先）。默认防护策略组中的规则...
后续步骤 应用创建完毕后，可以通过添加公网SLB实现公网访问，添加私网SLB实现同VPC内所有节点能够通过私网负载均衡访问您的应用。相关操作，请参见 添加负载均衡CLB 或 复用负载均衡CLB。联系我们 如果您在EDAS中使用容器服务K8s集群和...
背景信息 SSL是Netscape公司所提出的安全保密协议，在浏览器和Web服务器之间构造安全通道来进行数据传输，采用RC4、MD5、RSA等加密算法实现安全通讯。国际互联网工程任务组（IETF）对SSL 3.0进行了标准化，标准化后更名为安全传输层协议...
如果要进行数据分析，例如求最值、求和、统计行数等，您可以使用Search接口的统计聚合功能或者SQL查询来实现。具体操作，请参见 统计聚合 和 SQL查询。如果要快速导出数据，而不关心整个结果集的顺序时，您可以使用ParallelScan接口和...
组合模式是指将EDAS原来集应用生命周期管理、可...后续步骤 应用创建完毕后，可以通过添加公网SLB实现公网访问，添加私网SLB实现同VPC内所有节点够能通过私网负载均衡访问您的应用。相关操作，请参见 添加负载均衡CLB 或 复用负载均衡CLB。
应用接入 功能 功能说明 容器服务Kubernetes版中的应用自动接入 适合部署在容器服务Kubernetes版中的Java应用，通过安装组件ack-onepilot实现自动接入。手动接入 适合所有非容器化方式部署的Java应用，包括运行在线下IDC以及其他云上的Java...
本文为您介绍如何通过DataWorks实现MaxCompute Spark作业的配置与调度。前提条件 已创建ODPS Spark节点，详情请参见 创建并管理MaxCompute节点。使用限制 当ODPS Spark节点选择Spark3.x版本时，若提交节点报错，请 提交工单 联系技术支持...
使用Nginx-Ingress-tracing实现链路追踪 应用管理 应用列表 列出全量接入的应用列表，并展示典型监控指标，如应用的请求数、错误数、耗时等。应用列表 应用概览 应用概览页面提供了应用的请求数、错误数、耗时、实例数等信息。应用概览 ...
使用Nginx-Ingress-tracing实现链路追踪 应用管理 应用列表 列出全量接入的应用列表，并展示典型监控指标，如应用的请求数、错误数、耗时等。应用列表 应用概览 应用概览页面提供了应用的请求数、错误数、耗时、实例数等信息。应用概览 ...
本文为您介绍通过配置AMQP服务端订阅，实现企业服务器通过接入AMQP客户端，接收路灯设备数据的完整流程。前提条件 已接入设备和上报数据。具体操作，请参见 设备接入和上报数据。准备开发环境 本文AMQP客户端示例使用Java开发语言，推荐...
实现数据可视化分析Quick BI功能需要您同时安装Quick BI SDK和阿里云核心库。以Java SDK为例，您需要下载aliyun-java-sdk-core以及aliyun-java-sdk-quickbi-public。注意事项 您需要前往 阿里云 SDK 页面下载SDK并查看使用。获取已开放的...
资源组或队列（Queue）管理：如何配置热更新？如何处理Queue内应用分配不均？如何查看队列资源使用情况？组件日志管理 YARN服务组件.out日志为何会大量堆积且无法自动清理？组件问题汇总 RM RM处于Standby状态，无法自动恢复Active状态，该...
服务提供者属性列表 属性 是否必配 描述 类型 默认值 serviceInterface 是 服务对外提供的接口 Class java.lang.Object serviceVersion 否 服务的版本号 String 1.0.0.DAILY serviceGroup 否 服务的组名 String HSF clientTimeout 否 该...
前提条件 已创建Logtail机器组并添加相应服务器，创建机器组的步骤，请参见 创建用户自定义标识机器组（推荐）或 创建IP地址机器组。安装Logtail的主机需开放80（HTTP）端口和443（HTTPS）端口。ECS实例的端口由安全组规则控制，添加安全组...
服务端语言 操作指引 Java Java示例 说明 下文提供了Java语言的示例代码详解。Python Python示例 PHP PHP示例.NET .NET示例 Node.js Node.js示例 Go Go示例 Java示例 Java获取STS临时Token示例代码 说明 此处以集成3.1.1版本的原版STS SDK...
Java 针对Java应用，依赖Java SDK接入，运行Java应用中的某个方法。更多信息，请参见 Java任务。脚本任务 在线编写脚本运行，支持Shell、Python等脚本。更多信息，请参见 脚本任务。Golang 针对Go应用依赖Go SDK接入，运行Go应用中的某个...