@dbx-tools/databricks-零公交车

创建 Zerobus SDK 客户端并打开摄取流而不构建 区域特异性Databricks 端点你自己.

软件包 :

• 通过 Databricks 工作空间 URL/ id 发现 @dbx-tools/ 数据砖。 。 。 .
• 云/地区-认识零公交终点建设.
• 使用 Zerobus 前置 Env vars 和 Databricks 客户端 id 的可信查询 堕倒.
• Zerobus SDK周围的薄薄包裹,所以呼叫者仍然可以使用SDK-内生流 设置后的方法.

创建 Zerobus SDK 客户端

import { zerobus } from "@dbx-tools/databricks-zerobus";

const sdk = await zerobus.createSdk();

createSdk() 解决当前 Databricks 工作空间 URL/ id, 检测其云 通过区域 @dbx-tools/ 数据砖,并构建 该地区零公交的终点.

打开一条摄入流

import { zerobus } from "@dbx-tools/databricks-zerobus";

const sdk = await zerobus.createSdk();
const stream = await zerobus.createStream(sdk, "main.default.events");

await stream.ingestRecord({
  id: crypto.randomUUID(),
  event_type: "clicked",
  created_at: new Date().toISOString(),
});

createStream() 读取 ZEROBUS_DATABRICKS_CLIENT_ID 编号 : ZEROBUS_DATABRICKS_CLIENT_SECRET后退至未加前缀 DATABRICKS_CLIENT_ID 编号 : DATABRICKS_CLIENT_SECRET。使用前缀变量 当该应用程序使用零客车摄入的单独证书时.

此软件包不建模记录或主题 。 它只会解决正确的SDK 客户端和流端,再将叶子摄取语义到Zerobus.

模块

• zerobus - 说吧 createSdk() 财务报告和审定财务报表 createStream()。 。 。 .

此软件包没有 AppKit 依赖性 。 工作空间和云检测 授权 @dbx-tools/ 数据砖。 。 。 .