High Level REST Client（7.x）
开启阿里云Elasticsearch实例的自动创建索引功能。具体操作步骤请参见 配置YML参数。如果未开启会提示如下报错。配置阿里云Elasticsearch实例的白名单，确保网络互通。如果运行Java代码的服务器在公网环境下，可通过阿里云Elasticsearch...
High Level REST Client（6.7.x）
连通前，需要开启阿里云Elasticsearch实例的公网地址，并修改公网地址访问白名单，将服务器的公网IP地址加入白名单中。具体操作步骤请参见 配置实例公网或私网访问白名单。重要 如果您的客户端处在家庭网络或公司局域网中，您需要将局域网...
步骤三：调用SDK收发消息
groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-client-java</artifactId><version>5.0.4</version></dependency>生产消息 在已创建的Java工程中，创建发送普通消息程序并运行，示例代码如下：package doc;...
接入方式
开启自动提交（不推荐）在开启自动提交的情况下，客户端会定时向kafka服务端提交已拉取的位点，与本地消费逻辑是否成功无关。因此在由于网络、业务信息延迟等问题导致消息消费失败的情况下，该条消息将被跳过。2.顺序消费 Linkedmall消息在...
通过Flink导入数据
云数据库 SelectDB 版 兼容Apache Doris，支持通过Flink Doris Connector，将Kafka中的非结构化数据以及MySQL等上游业务数据库中的变更数据，实时同步到 云数据库 SelectDB 版 中，有效地满足海量数据的分析需求。功能介绍 Flink Doris ...
通过ES-Hadoop将HDFS中的数据写入Elasticsearch
plugins><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-shade-plugin</artifactId><version>2.4.1</version><executions><execution><phase>package</phase><goals><goal>shade</goal></goals>...
Upsert Kafka
Upsert Kafka结果表在使用精确一次语义时，写入的Kafka集群必须开启事务功能，且仅支持Apache Kafka 0.11及以上版本的集群。语法结构 CREATE TABLE upsert_kafka_sink(user_region STRING,pv BIGINT,uv BIGINT,PRIMARY KEY(user_region)NOT...
Java API Client(8.x)
连通前，需要开启阿里云Elasticsearch实例的公网地址，并修改公网地址访问白名单，将服务器的公网IP地址加入白名单中。具体操作步骤请参见 配置实例公网或私网访问白名单。重要 如果您的客户端处在家庭网络或公司局域网中，您需要将局域网...
默认接入点收发消息
groupId>org.apache.kafka</groupId><artifactId>kafka-clients</artifactId><version>2.4.0</version></dependency><dependency><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId><version>1.7.6...
在ECI中访问HDFS数据
Apache Hadoop下载地址请参见 Hadoop下载，建议选用的Apache Hadoop版本不低于2.7.2，本文档中使用的Apache Hadoop版本为Apache Hadoop 2.7.2。解压Apache Hadoop压缩包到指定文件夹。tar-zxvf hadoop-2.7.2.tar.gz-C/usr/local/修改core-...
通过CLB七层监听获取客户端真实IP
Apache服务器 当Apache作为后端服务器时，您可以通过检查Apache日志来判断是否成功获取到了客户端的真实IP地址。Apache日志文件默认路径为：/var/log/httpd/access_log 每行日志中，%{X-Forwarded-For}i 对应的字段中，第一个IP地址即为...
Token鉴权
开启Token鉴权后，只有使用Token加签的访问者才允许访问应用。下文介绍如何配置Token鉴权。背景信息 Token指系统颁发给应用的随机码，作用类似于安全证书。使用Token信息进行签名，可以让系统快速核验访问者身份，保证安全性。使用Web可视...
迁移数据上云
自建Kafka集群的接入点 bootstrap.servers=XXX.XXX.XXX.XXX:9092#消费者分区分配策略 partition.assignment.strategy=org.apache.kafka.clients.consumer.RoundRobinAssignor#Group 的名称 group.id=test-consumer-group 配置 producer....
一对一专家服务工作说明书
2.2 多软件环境部署 2.2.1 LAMP/WAMP环境部署 服务内容 服务范围 Apache 安装 系统要求：阿里云官方云服务器ECS镜像系统（Alibaba Cloud Linux、CentOS、Ubuntu、Windows Server，具体版本见附录）组件示例：Apache2.2、Apache2.4 PHP安装 ...
配置微服务治理
无损滚动发布 开启无损滚动发布后能将微服务的生命周期与K8s的生命周期打通，在分批发布时选择配置服务预热并开启无损滚动发布，可以在发布过程中看到以下效果：新发布的应用接收的流量呈预热曲线缓慢增长。旧的应用流量缓慢下降。在应用...
为HTTP触发器配置签名认证
函数计算 支持为HTTP触发器配置签名认证，当请求消息到达 函数计算 网关后，网关会对开启签名认证的HTTP触发器上的请求进行认证，您的函数无需再次对请求签名进行认证，只需关注业务逻辑即可。本文介绍如何通过控制台为HTTP触发器配置签名...
Android SDK开发指南
默认不开启IP测速 用户可以设置是否开启IP测速（true为开启IP测速功能，false为关闭IP测速功能）4.2.7 设置是否开启依据ISP网络区分域名缓存 DNSResolver.setIspEnable(true);是否开启依据ISP网络区分域名缓存 设置是否开启依据ISP网络区分...
开发场景：基于消息队列RocketMQ版实现环境隔离
步骤一：为应用开启RocketMQ消息灰度 Demo中的spring-cloud-c、spring-cloud-a应用分别为消息的生产者和消费者，通过添加启动参数-Dprofiler.micro.service.mq.gray.enable=true，在 SAE 上为其开启RocketMQ消息灰度。说明 RocketMQ消息...
SQL常见问题
SQL校验报错信息如下：org.apache.flink.table.api.ValidationException:SQL validation failed.Column types of query result and sink for 'vvp.default.sink' do not match.Cause:Sink column 'f1' at position 0 is of type INT but ...
访问Kafka数据源
使用 湖仓版（3.0）Spark访问kafka数据源时，需要开启ENI访问。spark.adb.eni.vswitchId 准备工作中获取的交换机ID。spark.adb.eni.securityGroupId 准备工作中获取的安全组ID。conf 其他参数 与开源Spark中的配置项基本一致，参数格式为 ...
创建集群
实时数据流（DataFlow）：是EMR平台上提供的实时计算一站式解决方案，拥有分布式、高吞吐量和高可扩展性的消息系统Kafka和基于Apache Flink官方产品Ververica提供的Flink商业内核两大组件，专注于解决实时计算端到端的各类问题，广泛应用于...
在Kafka异步消息通讯场景中实现链路追踪
消费方法需要带有一个org.apache.kafka.clients.consumer.ConsumerRecord或org.apache.kafka.clients.consumer.ConsumerRecords类型的参数。package arms.test.kafka;public class KafkaConsumeTest { public void testConsumer(){ ...
访问Redis数据源
loadedDf=sparkSession.read.format("org.apache.spark.sql.redis").option("keys.pattern",redisTableName+":*").schema(StructType(Array(StructField("name",StringType),StructField("age",IntegerType),StructField("address",...
通过Spark SQL访问MySQL数据
USING org.apache.spark.sql.jdbc 参数取值固定为 USING org.apache.spark.sql.jdbc。OPTIONS url：RDS MySQL实例的内网地址和端口。格式为：jdbc:mysql:/rm-bp1k87323a7ia*.mysql.rds.aliyuncs.com:3306 。dbtable：RDS MySQL的表名。格式...
搭建ThinkPHP框架
Apache（确保开启了mod_rewrite模块）配置示例：<IfModule mod_rewrite.c>Options+FollowSymlinks-Indexes RewriteEngine On RewriteCond%{REQUEST_FILENAME}!d RewriteCond%{REQUEST_FILENAME}!f RewriteRule^(.*)$index.php/$1[QSA,PT,L]...
CLB常见问题
从负载均衡服务中移除ECS实例 后端ECS实例频繁收到User-Agent为KeepAliveClient的请求 SLB后端服务器中TIME_WAIT状态连接数较多 负载均衡四层和七层监听的请求报文交互情况 会话保持 会话保持的功能无效 开启会话保持并选择重写Cookie时的...
常见问题
从负载均衡服务中移除ECS实例 后端ECS实例频繁收到User-Agent为KeepAliveClient的请求 SLB后端服务器中TIME_WAIT状态连接数较多 负载均衡四层和七层监听的请求报文交互情况 会话保持 会话保持的功能无效 开启会话保持并选择重写Cookie时的...
配置重写策略
路径（Path）重写 对于路径（Path）重写，云原生网关支持三种重写模式：精确重写、前缀重写和正则重写。精确重写 精确重写可以完全修改原始请求的Path。示例一 原始请求的Path为/app/test，但转发给后端服务的Path为/foo/bar，建议配置方式...
配置重写策略
路径（Path）重写 对于路径（Path）重写，云原生网关支持三种重写模式：精确重写、前缀重写和正则重写。精确重写 精确重写可以完全修改原始请求的Path。示例一 原始请求的Path为/app/test，但转发给后端服务的Path为/foo/bar，建议配置方式...
ALB配置会话保持
ALB 开启会话保持后，需要选择Cookie的处理方式，有植入Cookie和重写Cookie两种处理方式。植入Cookie：客户端第一次访问时，ALB 会在返回请求中植入Cookie（即 ALB 插入SERVERID和SERVERCORSID两个cookie；SERVERCORSID是以SERVERID为基础...
配置Sidecar注入策略
您可以参考 为网格内应用开启健康检查重定向，确定是否需要启用健康检查重写。Sidecar-injector部署节点选择 通过匹配标签的方式选择Sidecar注入器Pod部署的节点。单击 新增匹配标签，输入数据面集群节点标签的 名称 和 值，匹配具体的部署...
配置重写策略（公测中）
重写模式 自定义域名支持路由级别的重写，并且支持精确重写、通配符重写和正则重写三种重写模式。精确重写 精确重写是指当您请求中的 path 与匹配规则完全匹配时，使用替换规则中的字符串替代 path。例如，匹配规则为/old，替换规则为/new...
配置重写策略（公测中）
重写模式 自定义域名支持路由级别的重写，并且支持精确重写、通配符重写和正则重写三种重写模式。精确重写 精确重写是指当您请求中的 path 与匹配规则完全匹配时，使用替换规则中的字符串替代 path。例如，匹配规则为/old，替换规则为/new...
重写URL
如果您的源站资源的存放路径发生变化，但希望用户访问的URL路径保持不变，您可以在 全站加速 DCDN 节点上通过重写URL的方式，支持在用户请求需要回源时对URL中的路径和查询字符串（请求参数）进行改写，使用重写后的URL向源站请求资源。...
添加HTTPS监听
开启会话保持 选择是否开启会话保持。开启会话保持功能后，负载均衡会把来自同一客户端的访问请求分发到同一台后端服务器上进行处理。Cookie处理方式：植入Cookie：您只需要指定Cookie的过期时间。客户端第一次访问时，负载均衡会在返回...
添加HTTP监听
开启会话保持 选择是否开启会话保持。开启会话保持功能后，CLB 会把来自同一客户端的访问请求分发到同一台后端服务器上进行处理。HTTP协议会话保持基于Cookie。Cookie处理方式：植入Cookie：您只需要指定Cookie的过期时间。客户端第一次...
配置重写
您修改URI中指定内容时，需要配置重写规则，规则匹配后会302跳转到目标URI。您还可以根据实际需求配置多条重写匹配规则。本文为您介绍配置重写规则的操作方法。背景信息 如果您需要对请求URI进行修改，请添加重写功能。例如您的某些用户或...
【Path Rewrite】重写请求路径
本文介绍如何配置重写请求路径。前提条件 已完成准备工作，并部署httpbin应用和sleep应用。具体操作，请参见 准备工作。操作步骤 为httpbin服务配置虚拟服务，当匹配到发往httpbin服务的请求路径为/get 时，将请求路径重写为/status/400。...
【Path Rewrite】重写请求路径
本文介绍如何配置重写请求路径。前提条件 已完成准备工作，并部署httpbin应用和sleep应用。具体操作，请参见 准备工作。操作步骤 为httpbin服务配置虚拟服务，当匹配到发往httpbin服务的请求路径为/get 时，将请求路径重写为/status/400。...
【Path Rewrite】重写请求路径
本文介绍如何配置重写请求路径。前提条件 已完成准备工作，并部署httpbin服务和sleep服务。具体操作，请参见 准备工作。操作步骤 使用istioctl工具，执行以下命令，为httpbin服务部署Waypoint代理。istioctl x waypoint apply-service-...
- 产品推荐
- 这些文档可能帮助您