产品概述
流计算StreamCompute StreamCompute 是阿里云提供的流计算引擎，提供使用类SQL的语言来进行流式计算。数据总线 DataHub 和StreamCompute无缝结合，可以作为StreamCompute的数据源和输出源，具体可参考 实时计算文档 流处理应用 用户可以...
Deployment
streamcompute.onaliyun.com deploymentHasChanged boolean 已部署作业启动后是否被修改。true artifact Artifact 用户启动已部署作业必填的数据结构。flinkConf object Flink 配置。{"taskmanager.numberOfTaskSlots":"1"} logging ...
Job
streamcompute.onaliyun.com modifier string 修改者。27846363877456*modifierName string 修改者名称。streamcompute.onaliyun.com startTime long 作业实例启动时间。1660190835 endTime long 作业实例结束时间。1660277235 ...
CreateAIInstance
ProjectId String 是 1 所属项目ID AlgorithmId String 是 1 算子ID ComputeType String 是 StreamCompute 计算类型，取值范围：StreamCompute：流式计算 DataSource String 是 Camera 数据来源，取值范围：Camera：摄像头。需调用 ...
DescribeAIInstance
ComputeType String StreamCompute 计算类型 DataSource String Camera 数据来源 DataType String Picture 数据类型 ScheduleType String EVERYDAY 调度类型 ScheduleCycleDates String[1,4,6]JSON数组格式。含义随ScheduleType取值不同。...
数据上云工具
通过简单的配置即可完成数据的采集和传输，结合MaxCompute和StreamCompute可以轻松构建流式数据从采集到分析的一站式解决方案。LogStash的DataHub插件可以将日志数据实时上传到DataHub，并归档到MaxCompute表中。具体示例请参见 Logstash+...
常见问题
本文档根据实践，介绍了本案例中比较常见的两个问题及解决方法。...可能原因：您的RDS数据库与流计算项目不在同一区域。...参考文档：【流数据与大屏DataV】如何使用DTS，DataHub，StreamCompute，RDS及DataV搭建流数据大屏。
人流量展示
create table edgebus_sink(productKey varchar,deviceName varchar,flowrate int,t_start timestamp,t_end timestamp)with(type='edgebus_sink',topic='/sys/streamCompute/peopleFlowrate');insert into edgebus_sink select productKey,...
什么是云消息队列 Kafka 版？
数据处理集成：与StreamCompute、E-MapReduce、Spark、Storm等引擎集成。客户原声 以下是客户对 云消息队列 Kafka 版 的评价。商业版的云消息队列 Kafka 版完全兼容开源生态，接入方便容易，并且提供了优质的SLA保障，各种日常功能操作也...
CreateDeployment-创建已部署作业
namespace","name":"deploymentName","engineVersion":"vvr-6.0.0-flink-1.15","description":"this is a deployment description","creator":"27846363877456*","creatorName":"*@streamcompute.onaliyun.com","modifier":"27846363877456...
GetDeployment-获取已部署作业
namespace","name":"deploymentName","engineVersion":"vvr-6.0.0-flink-1.15","description":"this is a deployment description","creator":"27846363877456*","creatorName":"*@streamcompute.onaliyun.com","modifier":"27846363877456...
UpdateDeployment-更新已部署作业
namespace","name":"deploymentName","engineVersion":"vvr-6.0.0-flink-1.15","description":"this is a deployment description","creator":"27846363877456*","creatorName":"*@streamcompute.onaliyun.com","modifier":"27846363877456...
GetJob-获取作业实例
463e-967a-0b4107fd*","deploymentName":"flinktest","namespace":"namespacetest","executionMode":"BATCH","creator":"27846363877456*","creatorName":"*@streamcompute.onaliyun.com","modifier":"27846363877456*","modifierName":"*@...
StopJob-停止作业实例
463e-967a-0b4107fd*","deploymentName":"flinktest","namespace":"namespacetest","executionMode":"BATCH","creator":"27846363877456*","creatorName":"*@streamcompute.onaliyun.com","modifier":"27846363877456*","modifierName":"*@...
StartJobWithParams-启动作业实例
463e-967a-0b4107fd*","deploymentName":"flinktest","namespace":"namespacetest","executionMode":"BATCH","creator":"27846363877456*","creatorName":"*@streamcompute.onaliyun.com","modifier":"27846363877456*","modifierName":"*@...
ListDeployments-获取已部署作业列表
namespace":"default-namespace","name":"deploymentName","engineVersion":"vvr-6.0.0-flink-1.15","description":"this is a deployment description","creator":"27846363877456*","creatorName":"*@streamcompute.onaliyun.com",...
StartJob-启动作业实例（废弃）
463e-967a-0b4107fd*","deploymentName":"flinktest","namespace":"namespacetest","executionMode":"BATCH","creator":"27846363877456*","creatorName":"*@streamcompute.onaliyun.com","modifier":"27846363877456*","modifierName":"*@...
ListJobs-获取作业实例列表
967a-0b4107fd*","deploymentId":"354dde66-a3ae-463e-967a-0b4107fd*","deploymentName":"flinktest","namespace":"namespacetest","executionMode":"BATCH","creator":"27846363877456*","creatorName":"*@streamcompute.onaliyun.com",...
创建结果表
create table edgehub_output(productKey varchar,deviceName varchar,temperature int,productTime timestamp,inputTime timestamp,outputTime timestamp,delayTime bigint)with(type='edgebus_sink',topic='/sys/streamCompute/...
订单结算
CREATE TABLE edgebus_sink(orderId bigint,orderPrice double)WITH(type='edgebus_sink',topic='/sys/streamCompute/orderPrice');create view scan_goods as select cast(json_value(params,'$.goodsId')as bigint)as goodsId,cast(json_...
应用场景
数据处理引擎：可对接开源Storm、Samza、Spark以及EMR、Blink、StreamCompute等阿里云产品。数据中转枢纽 近10多年来，诸如KV存储（HBase）、搜索（Elasticsearch）、流式处理（Storm、Spark、Samza）、时序数据库（OpenTSDB）等专用系统...
查询MNS日志
实时计算：使用Spark、Storm、StreamCompute、Consumer Library等方式对MNS日志进行实时计算。例如：计算某个队列中，Top 10消息的产生者和消费者；计算生产和消费的速度，确认是否均衡；计算某些消费者的处理延时，确认是否存在瓶颈等。离...
版本说明
对接阿里云流计算引擎 StreamCompute；支持接入数据可视化工具 Grafana；支持在控制台将实例付费类型由按量付费改为预付费；支持数据查询的分页功能；增加三个 fill policy：linear（线性插值）、previous（按前一个值插值）和 fixed（固定...
OGG插件介绍
实时计算 在前一天的离线计算的基础数据上，我们可以写一个StreamCompute流计算的分析程序，很容易地对数据进行实时汇总，例如实时统计当前总的订单数，每种商品的销售量等。处理思路就是对于每一条到来的变更数据，可以拿到变化的数值，...
- 产品推荐
- 这些文档可能帮助您