什么是Keen的事件流處理服務(wù)?

事件流處理服務(wù)-Keen 基于 Apache Kafka ® 構(gòu)建，輕松從任何地方收集事件數(shù)據(jù)，添加豐富的屬性，并發(fā)送到您需要的任何地方。是一個(gè)專注于事件數(shù)據(jù)收集、豐富和轉(zhuǎn)換的服務(wù)平臺(tái)。它為用戶提供了一種方法來從各種來源收集事件數(shù)據(jù)，并通過多種方式豐富這些數(shù)據(jù)，如添加地理位置信息、設(shè)備類型等額外維度。同時(shí)，它也支持將數(shù)據(jù)發(fā)送到所需的任何地方，從而幫助用戶更好地理解和利用他們的數(shù)據(jù)資產(chǎn)。

 

什么是Keen的事件流處理服務(wù)接口？

Keen的事件流處理服務(wù)有哪些核心功能？

從任何來源串流 使用 Keen 強(qiáng)大的 REST API 和 SDK 從連接到互聯(lián)網(wǎng)的任何事物收集事件數(shù)據(jù)：您的網(wǎng)站、應(yīng)用程序、后端服務(wù)器、智能設(shè)備、第三方系統(tǒng)等。 使用從 JavaScript 到 Go 的超過 15 個(gè) SDK，從堆棧中的任何位置進(jìn)行 POST。 批量上傳生產(chǎn)系統(tǒng)的歷史數(shù)據(jù)。 使用流、網(wǎng)絡(luò)鉤子甚至 AMP-Analytics 輕松收集數(shù)據(jù)。 利用我們的數(shù)據(jù)建模指南，您可以使您的分析更加強(qiáng)大且易于訪問，同時(shí)還可以幫助您避免常見的初學(xué)者錯(cuò)誤（并且也可以節(jié)省您的時(shí)間！）
	豐富與轉(zhuǎn)變 為您捕獲的數(shù)十億個(gè)事件添加更多詳細(xì)信息。 使用豐富功能添加維度，例如位置、工作日、訪問設(shè)備等。 通過利用自定義訪問鍵，使用轉(zhuǎn)換從自定義數(shù)據(jù)源添加實(shí)體數(shù)據(jù)。 如果您希望收集網(wǎng)絡(luò)上的事件，請利用 Keen 的自動(dòng)收集器自動(dòng)收集具有豐富數(shù)據(jù)屬性的事件。
將數(shù)據(jù)發(fā)送到任何需要的地方 您的數(shù)據(jù)是您最有價(jià)值的資產(chǎn)之一。我們永遠(yuǎn)不會(huì)強(qiáng)迫您進(jìn)入數(shù)據(jù)孤島。 使用 Keen 安全存儲(chǔ)數(shù)據(jù)，以便使用 Keen Compute 進(jìn)行即時(shí)查詢和構(gòu)建實(shí)時(shí)數(shù)據(jù)產(chǎn)品。 將豐富的數(shù)據(jù)流式傳輸?shù)?Amazon S3，并在任何地方利用數(shù)據(jù)的力量。 使用我們的 API 連接到任何數(shù)據(jù)存儲(chǔ)或應(yīng)用程序。

 

Keen的事件流處理服務(wù)的核心優(yōu)勢是什么？

在哪些場景會(huì)用到Keen的事件流處理服務(wù)？

驗(yàn)證
Keen 支持兩種用于驗(yàn)證 HTTP API 請求的機(jī)制，一種用于 Kafka API 的驗(yàn)證機(jī)制。您想要使用的項(xiàng)目都需要API 密鑰。

驗(yàn)證請求的一種方法是使用名為“Authorization”的 HTTP 標(biāo)頭。此方法適用于每個(gè) API 調(diào)用。

所有 POST 都需要將“Content-Type”標(biāo)頭設(shè)置為“application/json”。

API 密鑰

您的每個(gè)項(xiàng)目都會(huì)有自己的一組 API 密鑰，您可以從項(xiàng)目的概述頁面檢索這些密鑰。

1.轉(zhuǎn)到PROJECT_ID
2.單擊“訪問”選項(xiàng)卡
3.選擇并復(fù)制適當(dāng)?shù)拿荑€

示例

import KeenAnalysis from 'keen-analysis';

const client = new KeenAnalysis({
  projectId: 'PROJECT_ID',
  readKey: 'READ_KEY',
  writeKey: 'WRITE_KEY'
});

開始使用
Keen 現(xiàn)在提供使用Apache Kafka作為流式傳輸和備份事件的接口之一的流式傳輸，從而輕松與外部系統(tǒng)集成。

事件生產(chǎn)

使用具有寫密鑰（Write Key）認(rèn)證的 Kafka 生產(chǎn)者可以將事件流傳輸?shù)揭粋€(gè)主題（Topic）。不需要提前創(chuàng)建主題，因?yàn)?auto.create.topics.enable=true。主題名稱在項(xiàng)目中必須是唯一的，且該名稱用于表示所傳輸事件的集合名稱。傳輸?shù)?Keen Kafka Inbound 集群的事件與通過 HTTP API 傳輸?shù)氖录幚矸绞较嗤?/p>

事件消費(fèi)

你可以使用具有讀密鑰（Read Key）認(rèn)證的 Kafka 消費(fèi)者來消費(fèi)事件流。同樣不需要提前創(chuàng)建主題，因?yàn)?auto.create.topics.enable=true。要從特定的事件集合進(jìn)行消費(fèi)，使用該集合名稱作為 Kafka 消費(fèi)者的主題名稱（如果你也使用 Kafka 進(jìn)行事件流傳輸，這將與 Kafka 生產(chǎn)者使用的主題名稱相同）。通過 HTTP API 和 Kafka 生產(chǎn)者發(fā)送的事件都將傳輸?shù)?Outbound Kafka 集群。你可以通過 HTTP API 發(fā)送一些事件，通過 Kafka 生產(chǎn)者發(fā)送另一些事件，然后使用 Kafka 消費(fèi)者消費(fèi)所有事件。所有可在 Outbound Kafka 集群中消費(fèi)的事件都會(huì)按照數(shù)據(jù)豐富（Data Enrichment）描述進(jìn)行豐富。

詳情參考：https://keen.io/docs/api/#kafka-event-streaming