使用Logview查看作业运行信息
I/O Records表示这个task的输入和输出的records数。单击Fuxi Task最右侧的查看列中的按钮或双击该Fuxi Task，您可以查看该Fuxi Task对应的Instance信息。说明 每个Fuxi Task由一个或多个Fuxi Instance组成。当Fuxi Task的输入数据量持续...
Bolt 协议的调用方式
获取 JDK 原生 Future 您可以通过以下的方式来获取 JDK 的原生的 Future 对象，再从任意地方去调用这个 Future 对象来获取结果。Future future=SofaResponseFuture.getFuture(true);true 表示清除线程上下文中的结果。若您不希望清除，可以...
合约间调用
例如，谁调用了这个合约（sender），本合约的ID是什么（self），当前合约能使用的 gas 是多少，当前合约本次收到多少资产。这些信息可以通过以下 API 获取到：Identity GetSender();返回一个Identity类型的数据，该数据表示本次调用是谁...
Dataphin已知一个任务的Task id，如何确认这个任务在...
概述 本文主要介绍已知一个任务的Task id，确认这个任务在哪个项目下，是什么任务的方法。详细信息 Dataphin已知一个任务的Task id，如何确认这个任务在哪个项目下，是什么任务呢？方法如下：可以随便打开一个实例的运行日志，然后将URL中...
使用限制
图像最短边不少于15px，最长边不大于8192px 创建异步图片翻译调用指南 创建异步批量图片翻译 3QPS 获取异步图片翻译结果调用指南 获取异步批量图片翻译结果 3QPS 图片语种诊断调用指南 图片语种诊断 3QPS 标题诊断调用指南 标题诊断 10QPS ...
组合类型
因此，在这个例子中，用两种语法时对每行都会调用 myfunc()三次。如果它是一个开销很大的函数，你可能希望避免这样做，所以可以用一个这样的查询：SELECT m.*FROM some_table,LATERAL myfunc(x)AS m;把该函数放在一个 LATERAL FROM 项中会...
配置熔断规则
熔断功能会在调用链路中某个方法出现不稳定时（例如某方法出现Timeout或异常比例升高），对这个方法的调用进行限制，让请求快速失败，避免此错误影响整个链路。关于熔断的相关信息，请参见 熔断结构图。熔断规则配置通常用于弱依赖降级场景...
输入和输出
同理，图示中 Task 调用之后，$Output 的取值是 Task 返回结果，如果Task的调用是异步回调模式，那么$Output 取值就是回调之后的返回结果；此时，流程继续执行$Output=OutputConstructor 表示在这个作用域范围内，OutputConstructor 构造...
ALIYUN:PAIDLC:Job
取值：ChiefWorker：当指定为这个值的时候，只要Chief的pod成功结束，那么就认为整个任务成功结束。AllWorkers（默认值）：必须是所有的Worker全部成功，才会认为整个任务成功。Settings Map 否 否 作业额外参数配置。无 CodeSource语法...
图片人脸检索
超过限制，API调用会被限流，这可能会影响您的业务，请合理调用。请求语法 POST/green/image/scan HTTPS|HTTP 请求头 该接口使用公共请求头，无特殊请求头。请参见 公共请求头。请求参数 名称 类型 是否必选 示例值 描述 clientInfo ...
查询调用链路
选择 RPC：新增 调用方法、服务名 这两个查询项。说明 查询时 服务名 字段受数据库限制，字符串长度超过 91 时将被忽略。选择 DB：新增 插件类型、数据库、数据源、数据类型 这四个查询项。选择 MQ：新增 消息类型、topic 这两个查询项。...
基本介绍
示例 以下的示例流程包含一个任务步骤，这个步骤调用一个函数计算的函数。version:v1 type:flow steps:type:task name:hello resourceArn:acs:fc:{region}:{accountID}:services/fnf_test/functions/hello 以下示例流程包含两个子步骤...
服务提供方或消费方流控
如果这个资源名的调用总和超过了这条规则定义的阈值，则触发限流。{some_origin_name}：适用于对特定的消费者限流的场景。只有来自这个调用者的请求才会进行流量控制。例如，资源 Ａ 配置了一条针对消费者 caller1 的规则，那么当且仅当...
合约间调用
在合约执行过程中，合约平台允许该合约调用其他合约。本文先对合约运行的上下文环境进行介绍，然后通过示例来讲解合约间的普通调用的方法。合约运行的上下文环境 合约上下文指的是合约运行环境。例如，合约调用方（sender）、当前合约的 ID...
CREATE CAST
这个参数被提供给必须实现这类造型的函数。不推荐在设计自己的数据类型时用它）。一个造型函数的返回类型必须等于目标类型或者能二进制强制到目标类型。通常，强制转换必须具有不同的源和目标数据类型。但是，如果它有一个带有多个参数的...
创建对象实例
使用以下语法调用构造函数方法：[NEW]obj_type({expr1|NULL}[,{expr2|NULL}][,.])obj_type是对象类型的构造函数方法的标识符；构造函数方法与以前声明的对象类型同名。expr1,expr2,…是一组表达式，其类型分别与对象类型的第一个属性、第二...
什么是调用链
调用链是指在分布式系统中，由多个服务相互调用形成的一系列调用关系。每当一个服务调用另一个服务时，就会形成一个调用链。调用链可以显示出服务之间的调用顺序和层次关系，帮助开发人员理解和追踪代码的执行流程。调用链的作用 在分布式...
阿里云官方事件源
例如，在创建ECS实例时，设置了实例自动释放时间，那到时就会产生type:AliyunServiceEvent的事件，这个事件不是主动调用的，而是阿里云平台调用的，此类事件就是AliyunServiceEvent事件。目前此类事件主要存在于预付费实例的到期自动释放...
LOAD
简介 这个命令把一个共享库文件载入到PolarDB服务器的地址空间中。如果该文件已经被载入，这个命令什么也不会做。只要调用包含C函数的共享库文件中的一个函数，这些共享库文件就会被自动载入。因此，一次显式的 LOAD 通常只在载入一个通过...
扫描并发控制
功能介绍 每个Task都有一个扫描并发额度，当Task实际运行的Split扫描并发数小于扫描并发额度时，Task可以启动一个新的Split扫描任务；反之，调度到该Task的Split需要等待已有的扫描任务结束后才可以执行。AnalyticDB for MySQL 支持节点的...
Co、递归调用
熟悉 co 的同学会知道 co 会将非 Promise 的调用转化为一个 Promise，这个地方的 Promise 意味着一个新的 Generator 的调用。这里的引用关系非常长，笔者展开 20 层之后，Percent 的占比还没有降低万分之一。这里线索中断了。下一个有用的...
使用Logview 2.0查看作业运行信息
每个Fuxi Task由一个或者多个Fuxi Instance组成，当用户的输入数据量变大时，MaxCompute会在每个Task启动更多的节点来处理数据，每个节点就是一个Fuxi Instance。例如，简单的MapReduce通常会产生两个Fuxi Task，一个是Map一个是Reduce，两...
使用示例
本文以C Link SDK中的Demo文件./demos/task_posix_demo.c 为例，介绍如何调用Link SDK的API，展示设备任务功能。背景信息 设备任务功能的更多信息，请参见 概述。设备任务 功能基于MQTT接入，开发过程中涉及MQTT接入的代码说明，请参见 ...
新建Session集群
资源配置 Task Managers 数量 填写Session集群的Task Managers的数量，需要为正整数，最小仅支持1个Task Managers，默认为1。Slot 数量 填写Session集群的Slot数量，需要为正整数，最小仅支持1个Slot，默认为8。Job Manager CPU Cores 填写...
值表达式
一个标量子查询 一个数组构造器 一个行构造器 另一个在圆括号（用来分组子表达式以及重载优先级）中的值表达式 在这个列表之外，还有一些结构可以被分类为一个表达式，但是它们不遵循任何一般语法规则。一个例子是 IS NULL 子句。列引用 ...
分布式多步骤事务
Serverless 工作流 在任务（Task）类型的步骤（Step）自带重试功能，如预定酒店这个步骤用下面的写法可以实现对FC.Unknown类型的错误指数退避。假设重试到达最大次数后 ReserveHotel 都无法成功，按照该步骤中 catch 的定义，ReserveHotel...
查看运行异常日志
在作业启动或者运行异常时，您可以查看运行异常日志。...单击Operators节点左侧的，展开查看每个Task的情况。单击慢Checkpoint对应的Task节点对应的 ID。在跳转的页面 运行Task Managers 页签，查看慢Checkpoint日志信息。
开发自定义组件示例
public class ReaderDemo extends Reader {/这个是用户在自定义数据源中定义的key，这是一个demo数据源的key，用户自定义的话，这个key值应该不同 public static final String DS_KEY="demo_ds;代码内部定义的task编号，没有使用到可以不用...
开发自定义组件示例
public class ReaderDemo extends Reader {/这个是用户在自定义数据源中定义的key，这是一个demo数据源的key，用户自定义的话，这个key值应该不同 public static final String DS_KEY="demo_ds;代码内部定义的task编号，没有使用到可以不用...
定期调度Zeppelin中的作业
ZeppelinOperator两种调度方式示例：Note级别调度 本示例总共有3个Task，分别为：生成数据：对应示例中的raw_data_task。把CSV格式转为Parquet格式：对应示例中的spark_etl_task。查询Parquet表：对应示例中的spark_query_task。每个Task都...
AttachCluster最佳实践
每个task可以根据需求进行设置各项参数#dag_desc.add_task('echoTask2',echo_task)#Dependencies设置多个task之间的依赖关系,echoTask2依赖echoTask;echoTask3依赖echoTask2#dag_desc.Dependencies={"echoTask":["echoTask2"],"echoTask2":...
任务管理
时间片轮转调度可以避免这个问题。基于时间片的轮转调度 时间片轮转调度使用时间片控制每个任务的执行时间，同等优先级的任务依次获得处理器被调度执行，每个任务可以运行的时间片是固定的，当任务的时间片用完后，该任务被放在对应优先级...
CREATE AGGREGATE
msfunc 前向状态转移函数的名称，在移动聚集模式中会为每个输入行调用这个函数。它非常像常规的转移函数，不过它的第一个参数和结果类型是 mstate_data_type，这可能与 state_data_type 不同。minvfunc 在移动聚集模式中用到的逆向状态转移...
SELECT TRANSFORM
使用 select transform 语法调用资源。创建测试表。create table testdata(c1 bigint,c2 bigint);测试表中插入测试数据。insert into table testdata values(1,4),(2,5),(3,6);执行select transform语句。select transform(testdata.c1,...
SELECT TRANSFORM
使用 select transform 语法调用资源。创建测试表。create table testdata(c1 bigint,c2 bigint);测试表中插入测试数据。insert into table testdata values(1,4),(2,5),(3,6);执行select transform语句。select transform(testdata.c1,...
LISTEN
只要命令 NOTIFY channel 被调用（不管是在这个会话中还是在另一个连接到同一数据库的会话中），所有当前正在该通知频道上监听的会话都会被通知，并且每一个会话将会接着通知连接到它的客户端应用。可以使用 UNLISTEN 命令在一个给定通知...
PAI语法
不同的PAI组件，其调用参数一般不同，通常情况下，PAI命令调用语法格式如下所示。PAI-name COMPONENT[-project algo_public][-Dparameter=value][-DinputTableName=inputTableName][-DoutputTableName=wpbc_outputTableName]如需进一步了解...
调用链分析
上图示例中可以看到，IP为10.219.152.24的Trace在慢Trace样本中占比最高，达到46.8%，并且IP为10.219.152.24的Trace仅占正常Trace的6.8%，说明大量的慢调用经过这个IP，且经过这个IP的调用链耗时都比较高，也许这个IP对应的主机出现了异常...
集成函数计算
Type:Task TaskMode:RequestComplete Action:FC:InvokeFunction Parameters:resourceArn:xxx invocationType:xxx body:xxx End:true 步骤二：配置调用参数 函数计算调用包含标识函数资源的ARN，函数调用方式及函数调用参数三个主要的参数。...
快速入门
本文以Paragraph级别调度为例，为每个Paragraph构建一个Task，然后串联起来构成一个链式DAG。代码示例如下。from airflow import DAG from datetime import datetime,timedelta from airflow.providers.apache.zeppelin.operators.zeppelin...
- 产品推荐
- 这些文档可能帮助您