概述
使用场景 Mars与PyODPS DataFrame使用场景如下：Mars 经常使用PyODPS DataFrame的 to_pandas()方法，将PyODPS DataFrame转换成Pandas DataFrame的场景。熟悉Pandas接口，但不愿意学习PyODPS DataFrame接口的场景。使用索引的场景。创建...
（邀测）MaxCompute Notebook使用说明
支持在MaxCompute Notebook Code中直接使用MaxCompute SQL语法操作MaxCompute数据，并支持将MaxCompute SQL执行结果可视化转为PyODPS DataFrame，同时支持PyODPS DataFrame与Pandas DataFrame互相转换。内置丰富函数库 MaxCompute Notebook...
创建DataFrame
import pandas as pd import numpy as np df=DataFrame(pd.DataFrame(np.arange(9).reshape(3,3),columns=list('abc')))注意事项 用Pandas DataFrame初始化时：PyODPS DataFrame会尝试对NUMPY OBJECT或STRING类型进行推断。如果一整列都为...
MapReduce API
df1=DataFrame(pd.DataFrame({'a':['name1','name2','name3','name1'],'b':[1,2,3,4]}))>>>df1 a b 0 name1 1 1 name2 2 2 name3 3 3 name1 4>>>df2=DataFrame(pd.DataFrame({'a':['name1']}))>>>df2 a 0 name1>>>df1.bloom_filter('a',df2...
使用Python访问Hologres
cur.close()conn.close()Pandas DataFrame快速写入Hologres最佳实践 使用Python时，经常会使用Pandas将数据转换为DataFrame，并对DataFrame进行处理，最终将DataFrame导入Hologres，此时希望将DataFrame快速导入Hologres。导入时候常用 to_...
GetEventStreaming-获取一个事件流的详细信息
testRole SourcePrometheusParameters object Source Prometheus 事件源 ClusterId string 集群 id c83555068b6*ad213f565f209 DataType string 数据类型 json Labels string 标签_name_=.*FilterPattern string 事件过滤规则，如果不指定...
ListEventStreamings-查询事件流
vsw-m5ev8asdc6h123456*InstanceSecurityGroupId string 实例安全组信息 sg-m5edtu24f12345*InstanceNetwork string 实例网络信息：PublicNetwork PrivateNetwork PublicNetwork SourceKafkaParameters object Source Kafka Parameters ...
查询转人工策略
返回数据 名称 类型 示例值 描述 Success Boolean true 表示请求是否成功 Data Object 转人工策略器配置 Id Integer 5506 转人工策略id SuccessTip String 转人工成功 转人工成功提示语 FailTip String 转人工失败 转人工失败提示语 Code ...
执行
print(type(iris[iris.sepalwidth].to_pandas(wrap=True)))返回结果：<class 'odps.df.core.DataFrame'>说明 PyODPS可以执行 open_reader 方法，通过 reader.to_pandas()转成Pandas DataFrame。详情请参见 表。立即运行设置运行参数 对于...
镜像管理
脚本示例如下：from odps.udf import annotate import pandas as pd@annotate("string,string->string")class SumColumns(object):def evaluate(self,arg1,arg2):#将输入参数转换为pandas DataFrame df=pd.DataFrame({'col1':arg1.split(',...
ListLegacyAgentStatusLogs-获取遗留坐席状态日志列表
请求参数 名称 类型 必填 描述 示例值 InstanceId string 是 实例 ID。ccc-test PageNumber integer 是 分页序号，范围 1-1000。1 PageSize integer 是 分页大小，范围 1-1000。100 StartTime long 是 开始时间，格式为 Unix 时间戳，单位...
CAST
注意其与json_parse和json_format的区别，json_parse只支持合法的JSON STRING转成JSON，而且可以转成JSON OBJECT，而cast(string as json)可以将任意STRING转成JSON STRING，JSON类型是STRING。cast(null as json)：将NULL值转换为JSON类型...
Python SDK示例：SQL
设置读取结果为pandas DataFrame#直接使用 reader 的 to_pandas 方法 with o.execute_sql('select*from dual').open_reader(tunnel=True)as reader:#pd_df 类型为 pandas DataFrame pd_df=reader.to_pandas()设置读取速度（进程数）说明 多...
内置函数
参数：map[string]any,map[string]any 返回值：map[string]any 使用示例：jsonMerge({"name":"Tom","age":10},{"name":"Tom","address":"beijing"})输出示例：{"name":"Tom","age":10,"address":"beijing"} length 介绍：用于获取array、...
数据类型
Sar String 编码信号分辨率比 Dar String 编码显示分辨率比 PixFmt String 像素格式 Level String 编码等级 Fps String 视频帧率 AvgFPS String 平均帧率 Timebase String 时基 StartTime String 起始时间 Duration String 时长，单位：秒 ...
排序、去重、采样、数据变换
您可以对DataFrame对象执行排序、去重、采样、数据变换操作。前提条件 您需要提前完成以下步骤，用于操作本文中的示例：准备示例表 pyodps_iris，详情请参见 Dataframe数据处理。创建DataFrame。from odps.df import DataFrame iris=...
GetMediaInfo-获取媒资内容信息
30 Fps string 视频帧率 24.0 AvgFPS string 平均帧率 24.0 Timebase string 时基 1/12288 StartTime string 起始时间 0.081706 Duration string 时长 216.206706 Bitrate string 码率 1001.594 NumFrames string 总帧数 5184 Lang string ...
数据输入输出
df.to_odps_table("parted_table",partition_col=["pt_col"]).execute()Pandas对象 您可以将本地Pandas的DataFrame对象和MaxFrame的DataFrame进行互相转换。当调用 read_pandas 方法时，Pandas对象将被上传至MaxCompute并在集群中使用。md_...
逻辑数仓SQL语法介绍
levenshtein_distance(string1,string2)bigint 返回string1和string2的Levenshtein编辑距离，即将string1改为string2所需的单字符编辑（插入、删除或替换）的最小数量。lower(string)varchar 将string转换为小写。lower('ABC')，返回值为'...
PyODPS常见问题
上传Pandas DataFrame至MaxCompute时，报错ODPSError，如何解决？通过DataFrame写表时，报错lifecycle is not specified in mandatory mode，如何解决？使用PyODPS写数据时，提示Perhaps the datastream from server is crushed，如何解决...
Sequence
MaxCompute类型 DataFrame类型 BIGINT INT64 DOUBLE FLOAT64 STRING STRING DATETIME DATETIME BOOLEAN BOOLEAN DECIMAL DECIMAL ARRAY<VALUE_TYPE>LIST<VALUE_TYPE>MAP,VALUE_TYPE>DICT,VALUE_TYPE>当 options.sql.use_odps2_extension=...
列运算
列运算 from odps.df import DataFrame iris=DataFrame(o.get_table('pyodps_iris'))lens=DataFrame(o.get_table('pyodps_ml_100k_lens'))为一个Sequence加上一个常量或执行sin函数时，这些操作将作用于Sequence中的每个元素。NULL相关...
绘图
本文为您介绍PyODPS DataFrame提供的绘图方法。如果您需要使用绘图功能，请先安装Pandas和Matplotlib。您可以在Jupyter中运行以下示例代码，并使用 pip install matplotlib 命令安装Matplotlib。绘图 单线图>>>from odps.df import ...
UpdateEventStreaming-修改一个事件流
testRole SourcePrometheusParameters object 否 Source Prometheus 事件源 ClusterId string 否 集群 id c83555068b6*ad213f565f209 DataType string 否 数据类型 json Labels string 否 标签_name_=.*Sink object 是 事件目标。...
CreateEventStreaming-创建一个事件流
testRole SourcePrometheusParameters object 否 Source Prometheus 事件源 ClusterId string 否 集群 id c83555068b6*ad213f565f209 DataType string 否 数据类型 json Labels string 否 标签_name_=.*Sink object 是 事件目标。...
概述
对于Pandas自定义函数，输入数据的类型是Pandas中定义的数据结构，例如pandas.Series和pandas.DataFrame等，您可以在Pandas自定义函数中使用Pandas和Numpy等高性能的Python库，开发出高性能的Python自定义函数，详情请参见 Vectorized User...
聚合操作
本文为您介绍DataFrame支持的聚合操作，以及如何实现分组聚合和编写自定义聚合。DataFrame提供对列进行HyperLogLog计数的接口。from odps.df import DataFrame iris=DataFrame(o.get_table('pyodps_iris'))常用聚合操作如下：使用 describe...
创建转人工策略
SuccessTip String 否 转人工成功 转人工成功提示语 FailTip String 否 转人工失败 转人工失败提示语 ShopId String 是 105574222_sg 店铺id SaasInstanceId String 是 dKeNtT7rxdEyU saas实例id I18nContext String 否 {"lang":"zh"} 格式...
更新转人工策略
Id Integer 是 108 策略id SuccessTip String 否 转人工成功 转人工成功提示语 FailTip String 否 转人工失败 转人工失败提示语 ShopId String 是 105574222_sg 店铺id SaasInstanceId String 是 dKeNtT7rxdEyU saas实例id I18nContext ...
VideoStream
0 Language string 视频流中使用的语言，格式为 BCP 47。en CodecName string 编码器名称。h264 CodecLongName string 编码器名称的全称。H.264/AVC/MPEG-4 AVC/MPEG-4 part 10 Profile string 档次。High CodecTimeBase string 编码器时间...
BlindTransfer-直接转接通话
调用BlindTransfer直接转接通话到其他坐席或某个技能组队列或外部号码，直接转接也叫盲转或单步转。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 ...
InitiateAttendedTransfer-发起咨询转接
调用InitiateAttendedTransfer咨询转接通话到其他坐席或某个技能组队列或外部号码，咨询转接也叫关注转或双步转。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码...
查询直播中心转推配置
调用DescribeLiveCenterTransfer查询直播中心转推配置。QPS限制 本接口的单用户QPS限制为100次/秒。超过限制，API调用会被限流，这可能会影响您的业务，请合理调用。更多信息，请参见 QPS限制。调试 您可以在OpenAPI Explorer中直接运行该...
ChangeResourceGroup-DBS资源转组API
资源转组。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。调试 授权信息 下表是API对应的授权信息，可以在RAM权限策略语句的 Action 元素中使用，用来给...
GetVideo-获取一个视频的信息
2021-01-21T07:40:53.955Z VideoSTTModifyTime string 语音转文字的更新时间。2021-01-21T07:40:53.95Z ProcessFailReason string 视频处理的失败原因。Timeout CreateTime string 视频加入媒体集的时间。2021-01-21T07:40:41.683Z ...
Python SDK常见问题
上传Pandas DataFrame至MaxCompute时，报错ODPSError，如何解决？通过DataFrame写表时，报错lifecycle is not specified in mandatory mode，如何解决？使用PyODPS写数据时，提示Perhaps the datastream from server is crushed，如何解决...
QueryDomainByDomainName-根据域名名称查询域名信息
操作 访问级别 资源类型 条件关键字 关联操作 domain:QueryCommonInfo Read Domain acs:domain:*:{#accountId}:domain/{#DomainName} 无 无 请求参数 名称 类型 必填 描述 示例值 UserClientIp string 否 用户 IP。127.0.0.1 Lang string ...
DescribeDownloadTask-查询下载任务列表
1663162216000 TargetType string 下载目标类型，返回值如下：OSS URL URL TargetPath string 当 TargetType=OSS时，返回数据下载目标路径。test_db/path Progress string 已导出表数量/需导出表总数量。0/0 GmtCreate string 任务创建时间...
QueryDomainByInstanceId-根据域名实例编号查询域名...
操作 访问级别 资源类型 条件关键字 关联操作 domain:QueryCommonInfo Read Domain acs:domain:*:{#accountId}:domain/{#DomainName} 无 无 请求参数 名称 类型 必填 描述 示例值 UserClientIp string 否 用户 IP，可以设置为 127.0.0.1。...
数据类型
AliyunFormatInfo 格式信息类型 名称 类型 描述 NumStreams String 媒体流总数。NumPrograms String 节目流总数。FormatName String 容器、封装格式简述名。FormatLongName String 容器、封装格式长述名。StartTime String 起始时间。...
- 产品推荐
- 这些文档可能帮助您