使用SASL登录认证Kafka服务
使用SASL登录Kafka集群 本文以SASL/SCRAM-SHA-512机制为例，使用Kafka自带的Producer和Consumer执行作业，介绍客户端如何认证登录Kafka服务。使用SSH方式登录Kafka集群，详情请参见 登录集群。执行以下命令，创建用于登录的用户名和密码。...
ModelScope魔搭社区
本文介绍如何通过 ModelScope魔搭社区 中的 多模态表征开源模型 进行 多模态向量生成，并入库至向量检索服务DashVector中进行向量检索。ModelScope魔搭社区 旨在打造下一代开源的模型即服务共享平台，为泛AI开发者提供灵活、易用、低成本的...
接入VNode（手动）
如果您在线下IDC或者阿里云ECS上自建了Kubernetes集群，您需要在集群中部署虚拟节点（VNode）来使用ECI。本文为您介绍如何配置证书并手动创建VNode，以便在自建Kubernetes集群中可以使用ECI。前提条件 已部署好Kubernetes集群，且集群的...
快速开始使用EMR Kafka
本文为您介绍如何创建E-MapReduce（简称EMR）Kafka集群、Kafka访问的设置，使用Kafka Topic和Kafka Connect服务，帮您快速了解和上手使用EMR Kafka。创建EMR Kafka集群 该部分内容为您简单介绍如何创建Kafka集群，更详细的创建操作，请参见...
产品优势
依托阿里云多年沉淀AI算法，为客户提供全新对话式交互体验 业内先进的对话式AI技术 本产品基于达摩院自研超大规模多模态大模型、多领域融合意图识别大模型等业内先进AI技术，构建有知识、有情感、主动式、多模态的新一代对话引擎，多项核心...
实时消费Kafka数据
当您需要将Kafka数据写入 云原生数据仓库AnalyticDB PostgreSQL版，且不希望使用其他数据集成工具时，可以通过实时数据消费功能直接消费Kafka数据，减少实时处理组件依赖，提升写入吞吐。Apache Kafka是一个容错、低延迟、分布式的发布-...
多媒体分析：Python SDK使用说明
本文为您介绍多媒体分析Python SDK的接口详情以及使用Python SDK调用算法服务和查询结果的示例。步骤一：安装Python SDK 环境依赖Python 3及其以上版本，安装命令如下。wget ...
解决方案：免费体验AnalyticDB PostgreSQL版以文搜图
为了能够处理这些非结构化数据，通常会使用人工智能技术提取这些非结构化数据的特征，并将其转化为特征向量，再对这些特征向量进行分析和检索以实现对非结构化数据的处理。通过构建云原生数据仓库 AnalyticDB PostgreSQL版 向量检索引擎和...
Node.js SDK收发消息
本文介绍如何使用Node.js SDK通过接入点接入 云消息队列 Kafka 版 并收发消息。环境配置 安装GCC 安装Node.js 重要 Node.js版本必须大于等于4.0.0。安装OpenSSL 安装C++依赖库 执行以下命令切换到yum源配置目录/etc/yum.repos.d/。cd/etc/...
接入VNode（VNodectl工具）
如果您在线下IDC或者阿里云ECS上自建了Kubernetes集群，您需要在集群中部署虚拟节点（VNode）来使用ECI。为了能够方便地接入和管理VNode，ECI提供了VNodectl命令行工具。本文为您介绍如何使用VNodectl工具自动创建VNode，以便在自建...
使用LDAP用户鉴权
本文为您介绍EMR Kafka如何启用LDAP用户进行鉴权，以及详细使用的示例。前提条件 已创建DataFlow集群，且选择了Kafka和OpenLDAP服务。创建集群详情，请参见 创建DataFlow Kafka集群。使用限制 适用于EMR-3.44.0之后版本、EMR-5.10.0之后...
设备分发
使用限制 支持在所有已开通物联网平台的地域之间分发设备。使用场景 设备提前烧录：在设备出厂时，无需对设备的不同地域和不同实例的连接信息进行硬编码，仅需对设备统一烧录全球统一接入点信息（无地域信息）。设备出厂后，在物联网平台...
使用MirrorMaker 2（on Connect）跨集群同步数据
本文通过示例为您介绍如何使用MirrorMaker 2（简称MM2）on Kafka Connect跨集群同步数据。背景信息 使用场景 Kafka MM2适用于下列场景：远程数据同步：通过MM2，Kafka数据可以在不同地域的集群进行传输复制。灾备场景：通过MM2，可以构建...
数仓场景：增量数据实时统计
cd$KAFKA_HOME kafka-topics.sh-create-topic ods_order-replication-factor 1-partitions 1-bootstrap-server"192.168.*.*:9092,192.168.*.*:9092,192.168.*.*:9092"kafka-topics.sh-create-topic ods_customers-replication-factor 1-...
升级或禁止升级云助手Agent
云助手支持的功能取决于所使用的云助手版本。若当前版本的云助手不支持某一功能，您可能需要升级 云助手Agent，本文介绍如何升级和禁止升级 云助手Agent。云助手支持的功能与支持该功能的云助手最低版本号，请参见 安装云助手Agent。使用...
数仓场景：增量数据实时统计
kafka-topics.sh-create-topic ods_order-replication-factor 1-partitions 1-bootstrap-server"192.168.*.*:9092,192.168.*.*:9092,192.168.*.*:9092"kafka-topics.sh-create-topic ods_customers-replication-factor 1-partitions 1-...
区域统计
您可以通过Ganos时空服务预先设定地理围栏，并根据业务需求灵活使用时空函数，结合Lindorm流引擎的实时计算能力，实现基于地理围栏的实时区域统计功能。背景信息 在很多基于时空位置的场景中，都有根据地理区域范围进行聚合查询的需求，...
使用SSL加密Kafka链接
配置SSL功能 E-MapReduce Kafka集群提供以下两种配置SSL的方式：使用默认证书配置SSL：使用E-MapReduce默认创建的证书和默认配置方式快速启用SSL功能。自定义配置SSL：使用自定义证书和配置值启用SSL功能。E-MapReduce通过 server....
轨迹生成
创建流任务，使用 ST_MakeLine_Ts_Agg 函数将点拼接为轨迹，并按照输入的时间戳（Timestamp）列对数据进行排序，使用 LISTAGG 函数拼接时间戳，最后将计算结果写入结果表resultAgg1。CREATE FJOB lineAgg1(LOAD MODULE ganos;create stream...
使用Kafka（离线与实时）
size":"8000","runtime.error.topic.name":"kafka topic when runtime errors happens","runtime.error.topic.bootstrap.servers":"kafka bootstrap servers of error topic queue","skip_error":"false"} } 公共参数 参数名 是否必填 说明...
什么是智能对话机器人
为什么选择阿里云智能对话机器人 多模态智能问答，满足不同场景问答需求 支持单轮、多轮对话，支持多语言、多模态对话。可充分满足多样化对话需求。文档问答：将文档（PDF、doc/docx或TxT）导入系统后，机器人将形成基于有关文档的业务知识...
通过OpenTelemetry接入Unreal Engine Trace数据
在 工作负荷 页签中，选中 使用 C++ 的桌面开发 和 使用 C++ 的游戏开发 这两个工作负荷，如下图所示。在 单个组件 页签中，选中.Net Framework 4.8 SDK 和.NET Core 3.1 Runtime ，如下图所示。步骤二：获取 OpenTelemetry C++ SDK二进制...
Hudi
本文为您介绍如何使用Hudi连接器。背景信息 Apache Hudi是一种开源的数据湖表格式框架。Hudi基于对象存储或者HDFS组织文件布局，保证ACID，支持行级别的高效更新和删除，从而降低数据ETL开发门槛。同时该框架还支持自动管理及合并小文件，...
同步EMR Kafka数据至HBase
本文为您介绍如何使用Flume同步EMR Kafka集群的数据至EMR DataServing集群的HBase。前提条件 已创建DataLake集群，并且选择了Flume，详情请参见 创建集群。已创建DataServing集群，详情请参见 创建集群。已创建DataFlow集群，并且选择了...
操作指南概述
阿里云媒体处理MPS（ApsaraVideo Media Processing，原MTS）以经济、弹性和高可扩展的转换方法，将多媒体数据转码成适合在全平台播放的格式，并基于海量数据对媒体的内容进行多模态分析，实现智能审核、智能生产、版权保护等功能。...
应用场景
您可以通过控制台“渠道部署”功能，自助创建部署配置，包括但不限于：对话窗样式设置、对话窗首页功能配置（如问题推荐、置顶公告、活动卡片等）、机器人形象等功能。在APP及Web网页渠道，创建完毕后，您将获取一个聊天窗URL，您可以按需...
文档理解
功能优势 算法技术先进 依托阿里丰富的文档场景打磨的多模态文档识别与理解引擎，算法效果与性能指标处于先进水平。行业应用丰富 覆盖海关物流、司法、招投标、政务、金融财税等多行业多场景应用，可满足各行各业的文档处理需求。部署方式...
同步EMR Kafka数据至OSS
本文为您介绍如何使用Flume同步EMR Kafka集群的数据至阿里云OSS。前提条件 已开通OSS服务并创建OSS存储空间，详情请参见 开通OSS服务 和 创建存储空间。已创建DataLake集群，并且选择了Flume服务，详情请参见 创建集群。已创建DataFlow集群...
引擎简介
数据不出库，一站式AI分析与处理 Lindorm AI引擎支持对存储于宽表引擎中的文本、图像和音视频等非结构化数据执行多种类型的推理任务，例如计算机视觉CV（Computer Vision）、自然语言处理NLP（Natural Language Processing）、多模态、生成...
消息队列Kafka
本文为您介绍如何使用消息队列Kafka连接器。背景信息 Apache Kafka是一款开源的分布式消息队列系统，广泛用于高性能数据处理、流式分析、数据集成等大数据领域。Kafka连接器基于开源Apache Kafka客户端，为阿里云实时计算Flink提供高性能的...
同步EMR Kafka数据至Hive
本文为您介绍如何使用Flume同步EMR DataFlow集群的数据至EMR DataLake集群的Hive。前提条件 已创建DataLake集群，并且选择了Flume服务，详情请参见 创建集群。已创建DataFlow集群，并且选择了Kafka服务，详情请参见 创建集群。操作步骤 ...
基本概念
自定义组件 在 Quick BI 中，自定义组件(CustomComponent)定义是一个包含了 bootstrap、mount、unmount、update 属性的对象，包含了自定义组件具体的实现的逻辑。详细信息请参考 Lifecycle。举例/这是一个自定义组件 const CustomComponent...
Workers
使用 事件总线EventBridge 提供默认值的配置项：plugin.path rest.advertised.port topic.creation.enable listeners 不会传输至Kafka Connect的配置项。sasl.*ssl.*security.*rest.advertised.host.name rest.advertised.listener rest....
Workers
使用 云消息队列 Kafka 版 提供默认值的配置项：plugin.path rest.advertised.port topic.creation.enable listeners 不会传输至Kafka Connect的配置项。sasl.*ssl.*security.*rest.advertised.host.name rest.advertised.listener rest....
联络中心渠道中接入对话机器人
3.产品优势 业内先进的对话式AI技术：本产品基于达摩院自研超大规模多模态大模型、多领域融合意图识别大模型等业内先进AI技术，构建有知识、有情感、主动式、多模态的新一代对话引擎，多项核心对话技术取得多个国际权威评测第一名，先后...
2021年11月24日 渠道部署更新预告
渠道部署核心功能列表：功能模块 功能说明 渠道管理 支持构建多个渠道，每个渠道可绑定1个机器人，每个渠道有自己单独的部署链接 服务界面配置 支持配置聊天框样式、机器人头像、欢迎语、输入框引导语言等基础配置 ChatUI PRO 多模态配置 ...
Table/SQL JAR迁移至SQL
背景信息 本文将使用开源JDBC Connector写阿里云RDS的方式进行Table/SQL JAR迁移至SQL，因此需要额外配置附加依赖文件选项。实时计算Flink全托管版集群内置了商业化的RDS Connector，您也可以替换为开源JDBC Connector。商业化的RDS ...
基于函数计算快速搭建AI对话机器人
本文介绍如何使用函数计算，基于通义千问语言模型快速搭建AI对话机器人。背景信息 通义千问是阿里云推出的一个较大规模的语言模型，功能包括多轮对话、文案创作、逻辑推理、多模态理解、多语言支持等。通义千问能够与人类进行多轮的交互，...
Llama2-7B基于DSW的全参数微调训练
本文介绍如何使用 DSW 对Llama-2-7B-Chat模型进行全参数微调，以使模型更好地理解和适应特定的任务，提高模型在指定任务上的表现和性能。准备环境和资源 创建工作空间，详情请参见 创建工作空间。创建DSW实例，其中关键参数配置如下。具体...
Databricks Delta Lake数据入湖最佳实践
使用Spark Structured Streaming完成客户日志数据写入Delta Lake。本章架构图 步骤一：创建Kafka集群和Databricks 数据洞察集群 1.登录 阿里云E-MapReduce控制台。2.创建Kafka集群，详情参见 创建集群 3.登录 Databricks数据洞察控制台。4....
- 产品推荐
- 这些文档可能帮助您