ApsaraMQ for Kafka：建立FC Sink Connector

什麼是Function Compute？

Function Compute（Function Compute，FC）是一個事件驅動的全託管Serverless計算服務，您無需管理伺服器等基礎設施，只需編寫代碼並上傳，Function Compute會為您準備好計算資源，並以彈性、可靠的方式運行您的代碼。更多資訊，請參見什麼是Function Compute。

Function Compute能做什嗎？

• 利用函數實現業務訊息的處理，通過Function Compute平台開發、運行業務訊息處理邏輯，訂單處理，任務執行。

• 利用函數對訊息進行快速加工處理，ETL清洗。

• 利用Function Compute靈活擴充將訊息轉儲到指定VPC中的其他下遊系統。

• 利用函數串連訊息系統和其他阿里雲產品服務，將訊息資料發送給其他雲端服務系統。

建立訊息流程出任務

1. 登入雲訊息佇列 Kafka 版控制台，在概览頁面的资源分布地區，選擇地區。

2. 在左側導覽列，選擇Connector生態整合 > 工作清單。

3. 在工作清單頁面，單擊建立任務。

4. 在创建任务面板，設定任务名称和描述，配置以下參數，單擊儲存。

   • 任務建立

     1. 在Source（源）設定精靈，選擇数据提供方為訊息佇列 Kafka 版，設定以下參數，然後單擊下一步。

        參數	說明	樣本
        地區	選擇雲訊息佇列 Kafka 版源執行個體所在的地區。	華北2（北京）
        kafka 執行個體	選擇生產雲訊息佇列 Kafka 版訊息的源執行個體。	alikafka_post-cn-jte3****
        Topic	選擇生產雲訊息佇列 Kafka 版訊息的Topic。	demo-topic
        Group ID	選擇源執行個體的消費組名稱。 快速建立：推薦方案，自動建立以GID_EVENTBRIDGE_xxx 命名的 Group ID。 使用已有：請選擇獨立的Group ID，不要和已有的業務混用，以免影響已有的訊息收發	快速建立
        消費位點	選擇開始消費訊息的位點。 最新點位 最早點位	最新位點
        網路設定	選擇路由訊息的網路類型。 基礎網路 自建公網	基礎網路
        Virtual Private Cloud	選擇VPC ID。當網路設定設定為自建公網時需要設定此參數。	vpc-bp17fapfdj0dwzjkd****
        交換器	選擇vSwitch ID。當網路設定設定為自建公網時需要設定此參數。	vsw-bp1gbjhj53hdjdkg****
        安全性群組	選擇安全性群組。當網路設定設定為自建公網時需要設定此參數。	alikafka_pre-cn-7mz2****
        数据格式	資料格式是針對支援二進位傳遞的資料來源端推出的指定內容格式的編碼能力。支援多種資料格式編碼，如無特殊編碼訴求可將格式設定為Json。 Json（Json格式編碼，位元據按照utf-8 編碼為Json格式放入Payload。） Text（預設文字格式設定編碼，位元據按照utf-8編碼為字串放入Payload。） Binary（二進位格式編碼，位元據按照Base64編碼為字串放入Payload。）	Json
        批量推送条数	調用函數發送的最大批量訊息條數，當積壓的訊息數量到達設定值時才會發送請求，取值範圍為 [1,10000]。	100
        批量推送间隔（单位：秒）	調用函數的間隔時間，系統每到間隔時間點會將訊息彙總後發給Function Compute，取值範圍為[0,15]，單位為秒。0秒錶示無等待時間，直接投遞。	3

     2. 在Filtering（过滤）設定精靈，設定資料模式内容過濾發送的請求。更多資訊，請參見事件模式。

     3. 在Transform（转换）設定精靈，設定資料清洗，實現分割、映射、富化及動態路由等繁雜資料加工能力。更多資訊，請參見使用Function Compute實現訊息資料清洗。

     4. 在Sink（目标）設定精靈，選擇服务类型為Function Compute，配置以下參數。

        參數	說明	樣本
        函數	選擇已建立的Function Compute的函數。	test
        版本和別名	選擇服務版本或服務別名。 指定版本 指定別名	指定版本
        版本	函數變更的對應版本，一般選擇為最新版。當版本和別名設定為指定版本時配置。	LATEST
        别名	函數別名。當版本和別名設定為指定別名時配置。	test
        執行方式	選擇同步執行或非同步執行。	非同步
        投递格式	Object 格式：事件將會以對象（Object） 格式向下遊函數進行投遞。 ObjectList 格式：事件將會以對象數組（Array）格式向下遊函數進行投遞。	Object 格式
        事件	事件匯流排EventBridge通過JSONPath提取訊息中的資料，將指定的訊息內容路由到目標。 完整資料 資料提取 固定值 模板	完整資料

   • 任務屬性

     設定此任務的重試策略及無效信件佇列。更多資訊，請參見重試和死信。

5. 返回任务列表頁面，找到建立好的任務，在其右側操作列，單擊启用。

6. 在提示對話方塊，閱讀提示資訊，然後單擊确认。

   啟用任務後，會有30秒~60秒的延遲時間，您可以在任务列表頁面的状态欄查看啟動進度。

其他動作

在任务列表頁面，找到目標任務，在其右側操作列，執行其他動作。

• 查看任務詳情：單擊详情，在任務頁面，查看任務的基礎資訊、任務屬性及監控指標。

• 編輯任務配置：單擊编辑，在編輯任務面板，修改任務詳情及屬性。

• 啟停任務：單擊启用或者停用，然後在提示對話方塊，單擊确认。

• 刪除任務：單擊删除，然後在提示對話方塊，單擊确认。