Streaming Tunnel SDK示例（Python）
table('<table_name>')upload_session=tunnel.create_stream_upload_session(table.name,partition_spec='pt=test')with upload_session.open_record_writer()as writer:record=table.new_record()record[0]='test1' record[1]='id1' ...
No more record”
问题描述 Dataphin即席查询查空表报错“Read result failed:No more record”。问题原因 ODPS的SDK接口报错导致。解决方案 在即席查询开头加上参数set dataphin.odps.mcqa=false（关闭查询加速）即可。适用于 Dataphin 说明：本文适用于...
二次排序示例
This is an example ODPS Map/Reduce application.It reads the input table that*must contain two integers per record.The output is sorted by the first and*second number and grouped on the first number.*/public class ...
如何设置录制回调
{"domain":"live.aliyunlive.com","app":"live","stream":"hello","event":"record_started"} 其中domain、app、stream 分别为录制域名、应用名和流名，event为事件名，可以为record_started/record_paused/record_resumed。录制暂停事件回...
MYSQL深潜-剖析Performance Schema内存管理
} 状态迁移过程还是比较好理解的，由dirty_to_allocated和allocated_to_free的逻辑是更简单的，因为只有record状态是free时，它的状态迁移是存在并发多写问题的，一旦state变为dirty，当前record相当于已经被某一个线程占有，其它线程不会...
Pipeline示例
}@Override public void reduce(Record key,Iterator<Record>values,TaskContext context)throws IOException { while(values.hasNext()){ result.set(0,key.get(0));result.set(1,values.next().get(0));context.write(result);} } } ...
记录变量
说明 其中，field_definition如下所示：field datatype[[NOT NULL]{:=|DEFAULT} expression]记录变量声明：record1 {record_type|{table|view|cursor}%ROWTYPE|record2%TYPE};使用限制 记录变量仅允许出现在以下位置：在UPDATE语句中SET...
错误信息列表
Parser Record Error,line,record field size is mismatch with header 解析CSV记录出错，记录中域个数与标题不匹配。Parser Record Error,{{line}},id miss in record 解析CSV记录出错，缺少ID域。Parser Record Error,{{line}},from and ...
PyODPS读取分区表数据
with t.open_reader(partition='dt=20190715,region=beijing')as reader1:count=reader1.count print("第一种方式查询分区表数据：")for record in reader1:print record[0],record[1],record[2]#第二种方式如下。print("第二种方式查询...
ALIYUN:DirectMail:Domain
ALIYUN:DirectMail:Domain类型用于创建邮件推送的域名。语法 {"Type":"ALIYUN:DirectMail:Domain","Properties":{"DomainName":String } } 属性 属性名称 类型 必须 允许更新 描述 约束 DomainName String 是 否 域名。长度1-50，可以包含...
DescribeTemplate-查询模板
2020-12-10T10:00:00Z OssEndpoint string OSS 的域名。oss-cn-qingdao.aliyuncs.com OssFilePrefix string OSS 文件前缀 oss-prefix JpgOnDemand string JPG 的存储路径，用于按需截图。说明 仅限截图模板。osspath/snapshot/{AppName}/{...
创建触发器
ddl_command(id,ddl_text,tag,database,schema,objid,object_type,object_name)VALUES(default,ddl_text,TG_TAG,current_database(),current_schema,record_object.objid,record_object.object_type,record_object.object_name);...
Dataphin集成任务同步失败报“Record columns has no ...
问题描述 集成任务从 AS400->odps 同步失败报错 Record columns has no sourceColName[n5mont]。问题原因 Dataphin集成任务同步过程中存在字段大小写敏感校验。从源端数据库（AS400）读出来的字段为展示为大写，集成任务中配置的字段是小写...
查询直播域名录制配置
调用DescribeLiveRecordConfig查询直播域名下所有APP录制配置。使用说明 先获取主播流域名，再调用本接口查询直播域名下所有APP录制配置。QPS限制 本接口的单用户QPS限制为100次/秒。超过限制，API调用会被限流，这可能会影响您的业务，请...
Join示例
}@Override public void map(long key,Record record,TaskContext context)throws IOException { mapkey.set(0,record.get(0));mapkey.set(1,tag);for(int i=1;i<record.getColumnCount();i+){ mapvalue.set(i-1,record.get(i));} context....
DescribeTemplates-查询模板列表
2018-12-10T10:00:00Z OssEndpoint string OSS 的域名。oss-cn-qingdao.aliyuncs.com Id string 模板 ID。323*998-cn-qingdao TransConfigs object []转码配置列表。说明 仅限转码模板。Gop long 视频 Gop，单位：帧 50 Width long 视频...
记录类型和记录变量
TYPE IS RECORD 语句的语法为：TYPE rec_type IS RECORD(fields)其中 fields 是以下形式的一个或多个字段定义的逗号（,）分隔列表：field_name data_type[NOT NULL][{:=|DEFAULT} default_value]其中：参数 说明 rec_type rec_type 是分配...
多任务示例
MultiJobs*Running multiple job*/public class MultiJobs { public static class InitMapper extends MapperBase {@Override public void setup(TaskContext context)throws IOException { Record record=context.createOutputRecord();...
使用Java SDK管理告警
for(ResourceWebhookIntegration webhookIntegration:webhooks){ ResourceRecord record=new ResourceRecord();record.setId(webhookIntegration.getId());record.setTag(webhookIntegration.getName());record.setValue(JSON.toJSONString...
000 exceeded in column 8 in record 255.Set the ...
问题描述 即席查询报“Maximum column length of 100,000 exceeded in column 8 in record 255.Set the SafetySwitch property to false if you're expecting column lengths greater than 100,000 characters to avoid this error.”问题...
原生SDK概述
void reduce(Record key,Iterator<Record>values,TaskContext context)reduce方法，处理输入表的记录。void setup(TaskContext context)在Reduce阶段开始时，reduce方法之前调用。TaskContext 主要函数接口。主要接口 描述 TableInfo[]...
Interval分区
create table BIGTABLE_LOG(record_date DATE,col_1 VARCHAR2(2000),col_2 VARCHAR2(2000))PARTITION BY RANGE(record_date)INTERVAL(numtodsinterval(1,'day'))(PARTITION P1 VALUES LESS THAN(TO_DATE('2014-1-1','YYYY-MM-DD')));...
多线程下载示例
} private static void consumeRecord(Record record,TableSchema schema){ for(int i=0;i().size();i+){ Column column=schema.getColumn(i);String colValue=null;switch(column.getType()){ case BIGINT:{ Long v=record.getBigint(i);...
简单上传示例
创建StreamRecordPack，写入Record。提交上传。示例 import java.io.IOException;import java.util.Date;import com.aliyun.odps.Column;import com.aliyun.odps.Odps;import com.aliyun.odps.PartitionSpec;import ...
协同消费
如果设置为false，那么每条record处理完必须ack，后台提交点位会保证该点位之前的record全部被ack。offsetCommitTimeoutMs 点位的提交间隔，单位毫秒，默认30000ms，范围[3000,300000]sessionTimeoutMs 会话超时时间，心跳间隔会设为改置的...
Unique示例
}@Override public void reduce(Record key,Iterator<Record>values,TaskContext context)throws IOException { result.set(0,key.get(0));while(values.hasNext()){ Record value=values.next();result.set(1,value.get(1));} context....
多路输入输出示例
}@Override public void reduce(Record key,Iterator<Record>values,TaskContext context)throws IOException { long count=0;while(values.hasNext()){ Record val=values.next();count+(Long)val.get(0);} long mod=count%3;if(mod=0){ ...
SaveSingleTaskForModifyingDSRecord-提交修改DS记录...
操作 访问级别 资源类型 条件关键字 关联操作 domain:DnsSecSetting Write Domain acs:domain:*:{#accountId}:domain/{#DomainName} 无 无 请求参数 名称 类型 必填 描述 示例值 DomainName string 是 域名。example.com Lang string 否 ...
SaveSingleTaskForAddingDSRecord-提交创建DS记录任务
操作 访问级别 资源类型 条件关键字 关联操作 domain:DnsSecSetting Write Domain acs:domain:*:{#accountId}:domain/{#DomainName} 无 无 请求参数 名称 类型 必填 描述 示例值 DomainName string 是 域名。example.com Lang string 否 ...
视频直播将录制文件存储到OSS提示“The record ...
问题描述 阿里云视频直播将录制文件存储到对象存储OSS时，提示“The record content between starttime and endtime is empty”错误。问题原因 调用视频录制CreateLiveStreamRecordIndexFiles接口时传参的StartTime和EndTime不合规，从而...
使用Counter示例
}@Override public void reduce(Record key,Iterator<Record>values,TaskContext context)throws IOException { long count=0;while(values.hasNext()){ Record val=values.next();count+(Long)val.get(0);} result.set(0,key.get(0));...
Workbench
发布成应用后，通过API调用此机器人应用#会在最终的返回值的data中，得到自定义的任务结果 json_result='{"employees":[{"firstName":"Bill","lastName":"Gates"}]}' rpa.console.workbench.task_result(json_result)record record(status=...
VoiceRecordReport
record_file String 录音文件URL，URL有效期为7天。out_id String 扩展字段回传，将调用API时传入的字段返回。record_begin_time String 录音开始时间。请求示例[{"duration":0,"start_time":"2023-03-15 16:02:07","status_code":"200005...
通过Python SDK管理告警
True,'sms_enabled':True,'voice_enabled':True } record=ResourceRecord(user['user_id'],user['user_name'],user)res=client.create_resource_record(user_resource_name,record)print('[create user]')res.log_print()def get_user():...
VoiceRecordReport
record_file String 录音文件URL，URL有效期为7天。out_id String 扩展字段回传，将调用API时传入的字段返回。record_begin_time String 录音开始时间。请求示例[{"duration":0,"start_time":"2023-03-15 16:02:07","status_code":"200005...
VoiceRecordReport
record_file String 录音文件URL，URL有效期为7天。out_id String 扩展字段回传，将调用API时传入的字段返回。record_begin_time String 录音开始时间。请求示例[{"duration":0,"start_time":"2023-03-15 16:02:07","status_code":"200005...
VoiceRecordReport
record_file String 录音文件URL，URL有效期为7天。out_id String 扩展字段回传，将调用API时传入的字段返回。record_begin_time String 录音开始时间。请求示例 请求内容为JSON Array格式。[{"duration":0,"start_time":"2023-03-15 16:02...
VoiceRecordReport
record_file String 录音文件URL，URL有效期为7天。out_id String 扩展字段回传，将调用API时传入的字段返回。record_begin_time String 录音开始时间。请求示例[{"duration":0,"start_time":"2023-03-15 16:02:07","status_code":"200005...
Go SDK
if recordCount%1000=0 { fmt.Println("Commit offset",record.GetSequence())offset.Sequence=record.GetSequence()offset.Timestamp=record.GetSystemTime()offsetMap:=map[string]datahub.SubscriptionOffset{shardId:offset} err:=dh....
PyODPS查看一级分区
with o.execute_sql('select*from user_detail WHERE dt=\'20190715\'').open_reader()as reader4:print reader4.raw for record in reader4:print record["userid"],record["job"],record["education"]#使用ODPS的DataFrame获取一级分区。...
- 产品推荐
- 这些文档可能帮助您