在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.execallocatoroption
s 是直接从该存储库复制的。它有效,但我不确定这是否是最佳选项列表。也许您必须根据您的需要调整它们。
以上是AWS Lambda 中的 Websocket URL 超时达到错误的详细内容。更多信息请关注PHP中文网其他相关文章!