goder/bygdata
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

change sqs

Browse Source
This commit is contained in:
goder-zhang 2026-02-25 16:08:11 +00:00
parent d81eecf048
commit c1c6bfe6cf
2 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
.gitignore vendored Normal file
View File

@ -0,0 +1,3 @@
# 忽略日志目录和文件
log/
*.log.*

5
api/v1/sqs/aws-sqs.go
View File

@ -207,6 +207,11 @@ func processMessage(svc *sqs.SQS, queueURL string, msg *sqs.Message) {
// 处理不同类型的消息 // 处理不同类型的消息
var processErr error var processErr error
global.GVA_LOG.Info("Processing create user action", zap.String("msgId", msgId),
zap.Int32("msg_action", int32(sqsMessage.Action)), zap.String("msg_content", sqsMessage.Content))
if sqsMessage.Action == awssqs.SqsActionCreateUser { if sqsMessage.Action == awssqs.SqsActionCreateUser {
// TODO: 实现创建用户的逻辑 // TODO: 实现创建用户的逻辑
global.GVA_LOG.Info("Processing create user action", zap.String("msgId", msgId)) global.GVA_LOG.Info("Processing create user action", zap.String("msgId", msgId))