在AWS Lambda中使用Websocket时，有时会遇到Websocket URL超时错误。这个问题可能导致无法建立或保持与Websocket的连接，影响应用程序的正常运行。本文将为大家介绍这个问题的原因和解决方法，帮助开发者解决Websocket URL超时错误，确保应用程序的稳定性和可靠性。无论是初学者还是有经验的开发者，都将从本文中获得有关AWS Lambda和Websocket的宝贵信息。
问题内容
我正在使用 go 语言开发 aws lambda。我正在部署 go lang 代码，使用 chromedp 和 docker 映像，并出现 websocket url 超时错误。我的 lambda 设置为 3008 mb ram 内存、512mb 存储和 15 分钟超时。你能找出问题所在以及如何解决这个问题吗？这是文件 main.go 和 dockerfile
文件 main.go （chromedp 部分）
func getpage(url string, linenum string, stationnm string) {
// settings for crawling
ctx, cancle := chromedp.newcontext(
context.background(),
chromedp.withlogf(log.printf),
)
defer cancle()
opts := []chromedp.execallocatoroption{
chromedp.disablegpu,
chromedp.nosandbox,
chromedp.headless,
chromedp.flag("no-zygote", true),
chromedp.flag("single-process", true),
chromedp.flag("homedir", "/tmp"),
chromedp.flag("data-path", "/tmp/data-path"),
chromedp.flag("disk-cache-dir", "/tmp/cache-dir"),
chromedp.flag("remote-debugging-port", "9222"),
chromedp.flag("remote-debugging-address", "0.0.0.0"),
chromedp.flag("disable-dev-shm-usage", true),
}
allocctx, cancel := chromedp.newexecallocator(ctx, opts...)
defer cancel()
ctx, cancel = chromedp.newcontext(allocctx, chromedp.withlogf(log.printf))
defer cancel()
var htmlcontent string
ch := chromedp.waitnewtarget(ctx, func(i *target.info) bool {
return strings.contains(i.url, "/timetable/web/")
})
}
文件 dockerfile
FROM public.ecr.aws/lambda/provided:al2 AS build
ENV GO111MODULE=on \
CGO_ENABLED=0 \
GOOS=linux \
GOARCH=amd64
# Get rid of the extension warning
RUN mkdir -p /opt/extensions
RUN yum -y install golang
RUN go env -w GOPROXY=direct
# Clone git, copying go.mod, go.sum, main.go
WORKDIR /var/task/
RUN yum install git -y
RUN git clone https://github.com/seedspirit/NaverCrawler-CICD-go.git
RUN cp NaverCrawler-CICD-go/main.go /var/task/
RUN cp NaverCrawler-CICD-go/go.mod /var/task/
RUN cp NaverCrawler-CICD-go/go.sum /var/task/
# cache dependencies
RUN go mod download
RUN go build -o main .
FROM public.ecr.aws/lambda/provided:al2
COPY --from=build /var/task/main /var/task/main
# Install Chrome dependencies
RUN curl https://dl.google.com/linux/direct/google-chrome-stable_current_x86_64.rpm -o chrome.rpm && \
yum install -y ./chrome.rpm && \
yum install -y fontconfig libX11 GConf2 dbus-x11
ENTRYPOINT ["/var/task/main"]解决方法
建议使用 chromedp/headless-shell 因为它很小而且更适合aws lambda。
我刚刚使用 chromedp/headless-shell 测试了一个简单的演示，它可以工作。
dockerfile：
from golang:1.20.4-alpine3.17 as builder workdir /app copy go.mod go.sum ./ run go mod download copy . . run go build -o main from chromedp/headless-shell:113.0.5672.93 workdir /app copy --from=builder /app/main . entrypoint [ "./main" ]
main.go：
package main
import (
"context"
"encoding/json"
"fmt"
"log"
"os"
"github.com/aws/aws-lambda-go/lambda"
"github.com/chromedp/chromedp"
)
func Handler(_ context.Context, _ json.RawMessage) error {
opts := []chromedp.ExecAllocatorOption{
chromedp.NoSandbox,
chromedp.Flag("disable-setuid-sandbox", true),
chromedp.Flag("disable-dev-shm-usage", true),
chromedp.Flag("single-process", true),
chromedp.Flag("no-zygote", true),
}
ctx, cancel := chromedp.NewExecAllocator(context.Background(), opts...)
defer cancel()
ctx, cancel = chromedp.NewContext(ctx, chromedp.WithDebugf(log.Printf))
defer cancel()
var content string
if err := chromedp.Run(ctx, chromedp.Tasks{
chromedp.Navigate("https://example.com/"),
chromedp.Text("body > div > p:nth-child(2)", &content),
}); err != nil {
log.Fatal(err)
}
fmt.Println(content)
return nil
}
func main() {
if _, exists := os.LookupEnv("AWS_LAMBDA_RUNTIME_API"); exists {
lambda.Start(Handler)
} else {
err := Handler(context.Background(), nil)
if err != nil {
log.Fatal(err)
}
}
}
此示例基于 https://github.com/andiedie/chromedp- aws-lambda-示例。请注意，列出的 chromedp.execallocatoroptions 是直接从该存储库复制的。它有效，但我不确定这是否是最佳选项列表。也许您必须根据您的需要调整它们。
