Skip to content

Commit 771495e

Browse files
committed
refactor: remove enqueue_tweets function from extract_ecs.py, cleanup unused SQS logic
1 parent 12f446b commit 771495e

File tree

1 file changed

+0
-16
lines changed

1 file changed

+0
-16
lines changed

etl/src/birdxplorer_etl/extract_ecs.py

Lines changed: 0 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -325,19 +325,3 @@ def enqueue_note_status_update(note_id: str):
325325
except Exception as e:
326326
logging.error(f"Failed to enqueue note {note_id} to note-status-update queue: {e}")
327327

328-
329-
def enqueue_tweets(tweet_id: str):
330-
"""
331-
ツイート取得用のSQSキューにメッセージを送信
332-
"""
333-
message_body = json.dumps({"tweet_id": tweet_id, "processing_type": "tweet_lookup"})
334-
sqs_client = boto3.client("sqs", region_name=os.environ.get("AWS_REGION", "ap-northeast-1"))
335-
336-
try:
337-
response = sqs_client.send_message(
338-
QueueUrl=settings.TWEET_LOOKUP_QUEUE_URL, # 新しい環境変数を使用
339-
MessageBody=message_body,
340-
)
341-
logging.info(f"Enqueued tweet {tweet_id} to tweet-lookup queue, messageId={response.get('MessageId')}")
342-
except Exception as e:
343-
logging.error(f"Failed to enqueue tweet {tweet_id} to tweet-lookup queue: {e}")

0 commit comments

Comments
 (0)