Knative 实战：表格存储 + 钉钉，实现天气预报提醒

2023-11-12 20:49:23

导读

在上一篇文章中，我们介绍了如何利用 Knative Serverless 技术构建天气服务，提供了天气查询的 REST API 接口。本文将继续探讨如何使用 Knative 与表格存储通道服务集成，实现基于天气预报的钉钉提醒功能，让用户可以实时接收天气预报通知，防患未然。

表格存储通道服务介绍

表格存储通道服务是一种由表格存储提供的服务，允许 Knative 对接表格存储事件源，从而实现无服务器事件处理。当表格存储中指定的表发生变化时，通道服务会触发 Knative 服务处理这些变化。

集成 Knative 和表格存储通道服务

要将 Knative 集成到表格存储通道服务，我们需要执行以下步骤：

创建表格存储表：创建一个名为 "weather-events" 的表，并添加一个名为 "weather" 的列，用于存储天气信息。
配置通道：在 Knative 中配置通道，指定表格存储表的名称和事件类型。
创建 Knative 服务：创建 Knative 服务来处理表格存储事件。

钉钉消息通知实现

接下来，我们将构建 Knative 服务，当收到表格存储事件时，从事件中提取天气信息，并通过钉钉发送天气预报提醒。

package main

import (
    "context"
    "fmt"
    "log"

    "github.com/cloudevents/sdk-go/v2/event"
)

func main() {
    // 处理表格存储事件的 Knative 服务
    ctx := context.Background()
    e, err := event.Parse(ctx, r)
    if err != nil {
        log.Fatalf("event.Parse: %v", err)
    }

    // 提取天气信息
    weather, err := e.DataBytes()
    if err != nil {
        log.Fatalf("e.DataBytes: %v", err)
    }

    // 发送钉钉提醒
    if weather == "rain" {
        err := sendDingTalkMessage("明天有雨，记得带伞哦！")
        if err != nil {
            log.Fatalf("sendDingTalkMessage: %v", err)
        }
    }

    fmt.Printf("Weather forecast: %s", weather)
}