Polling機能の追加 #2
Merged
Polling機能の追加 #2
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
EndoNrak
commented
Sep 17, 2022
| @@ -0,0 +1,20 @@ | |||
| # -*- coding:utf-8 -*- | |||
There was a problem hiding this comment.
/management/commands 以下にBaseCommandを継承したクラスを作ると自作コマンドを登録できる
https://docs.djangoproject.com/en/4.1/howto/custom-management-commands/
| help = 'polling sqs and execute score_evaluations' | ||
|
|
||
| def add_arguments(self, parser): | ||
| parser.add_argument('interval', nargs='?', type=int, default=60) |
There was a problem hiding this comment.
ポーリングの際、sqsにメッセージがなかった時はinterval秒だけ次のメッセージ取得まで待つ
faultは60秒で任意の秒数を設定可能
| print("start polling") | ||
| while True: | ||
| _eval = self.execute() | ||
| if _eval is not None: |
There was a problem hiding this comment.
sqsにメッセージがなかった場合はNoneが返される
メッセージが取得できた場合には、評価が終了するとすぐに次のメッセージ取得を試行する
| } | ||
| return response | ||
|
|
||
| message = str(msg.SerializeToString()) | ||
| message = str(base64.b64encode(msg.SerializeToString())) |
There was a problem hiding this comment.
api-gateway経由のリクエストも一度base64decodeしてパースした後、
シリアライズしたメッセージをbase64encodeしてからsqsに登録する。
| @@ -33,13 +33,13 @@ def lambda_handler(event: dict, context): | |||
| "body": response, | |||
| "code": 200 | |||
| } | |||
| except: | |||
| except Exception as e: | |||
There was a problem hiding this comment.
tryで発生したエラーをすべてキャッチしてレスポンスに返す
|
コンテナ内でpollingがうまく動くことを確認した |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
sqsを指定秒数ごとにポーリングする