DEV Community

Python-T Point
Python-T Point

Posted on • Originally published at pythontpoint.in

🚨 Automate S3 ransomware response with Python

#googlecloud #cloud #devops #python

⏱ Minute 0-2 — Stop the Bleed

automate S3 ransomware response python

Immediate triage actions prevent further data loss and lock the attacker out.

📑 Table of Contents

  • ⏱ Minute 0-2 — Stop the Bleed
  • 🛡 Minute 2-10 — Contain and Assess
  • 🔍 Pull CloudTrail logs
  • 🚫 Revoke credentials
  • 🔀 Minute 10-X — Recovery Decision Tree
  • 🔐 Preventive Controls — Stop This From Happening Again
  • 🟩 Final Thoughts
  • ❓ Frequently Asked Questions
  • How can I trigger the Python restoration script automatically?
  • What if my bucket does not have versioning enabled?
  • Does Object Lock interfere with normal updates?
  • 📚 References & Further Reading

🛡 Minute 2-10 — Contain and Assess

Isolation of the compromised identity and extraction of audit logs give the context needed for remediation.

🔍 Pull CloudTrail logs

CloudTrail records every API call; filtering for the bucket reveals the malicious activity.

$ aws cloudtrail lookup-events -lookup-attributes AttributeKey=EventSource,AttributeValue=s3.amazonaws.com -max-results 10
{ "Events": [ { "EventId": "1234abcd-56ef-78gh-90ij-123456klmnop", "EventName": "PutObject", "EventTime": "-09-12T08:23:45Z", "Username": "compromised_user", "Resources": [ { "ResourceType": "AWS::S3::Object", "ResourceName": "prod-data/reports/-09-01.csv" } ], "CloudTrailEvent": "{...}" } ]
}
Enter fullscreen mode Exit fullscreen mode

Note the Username and the exact EventTime. Those values drive the next containment steps by identifying the precise request that introduced the payload.

🚫 Revoke credentials

Delete the access keys for the compromised user to prevent further API calls.

$ aws iam delete-access-key -user-name compromised_user -access-key-id AKIAEXAMPLEKEY
{ "ResponseMetadata": { "RequestId": "WXYZ9876QRST5432", "HTTPStatusCode": 200, "HTTPHeaders": { "x-amz-request-id": "WXYZ9876QRST5432", "date": "Tue, 12 Sep 08:35:12 GMT", "content-length": "0" }, "RetryAttempts": 0 }
}
Enter fullscreen mode Exit fullscreen mode

Key point: Revoking credentials cuts the attacker’s live channel, limiting the window of damage to the time before the deny policy takes effect.

🔀 Minute 10-X — Recovery Decision Tree

Based on versioning status and backup availability, choose the appropriate restoration path.

Critical question: Does the bucket have versioning enabled? (More onPythonTPoint tutorials)

If versioning is enabled: Use a Boto3 script to restore the latest non‑malicious version of each affected object.

If versioning is not enabled but a recent backup exists: Copy objects from the backup location back into the bucket.

If neither versioning nor backup is available: Take a forensic snapshot of the current state before deletion, then rebuild the dataset from source systems.

If none of the above: Escalate to the incident response manager for legal and business‑continuity guidance. 

# restore_objects.py
import boto3
import sys s3 = boto3.client('s3')
bucket = 'prod-data' def restore_latest(key): versions = s3.list_object_versions(Bucket=bucket, Prefix=key)['Versions'] # Find the most recent version that is not a zero‑byte ransomware payload for v in sorted(versions, key=lambda x: x['LastModified'], reverse=True): if v['Size'] > 0: s3.copy_object( Bucket=bucket, CopySource={'Bucket': bucket, 'Key': key, 'VersionId': v['VersionId']}, Key=key ) print(f"Restored {key} to version {v['VersionId']}") return print(f"No valid version found for {key}") if __name__ == '__main__': if len(sys.argv) < 2: print("Usage: python restore_objects.py ") sys.exit(1) restore_latest(sys.argv[1])
Enter fullscreen mode Exit fullscreen mode

What this does:

  • list_object_versions: Retrieves all versions for the given key, leveraging S3’s built‑in versioning data structure (a linked list of version IDs).
  • sorted( …, reverse=True): Orders versions newest first, providing O(n log n) ordering based on timestamps.
  • Size > 0: Filters out the zero‑byte ransomware payloads, ensuring only legitimate data is restored.
  • copy_object: Creates a new version that points to the good version, effectively rolling back without deleting the malicious version.

Key point: The script automates version selection, enabling rapid, consistent remediation across dozens of objects.

🔐 Preventive Controls — Stop This From Happening Again

Implementing layered defenses reduces the likelihood of future ransomware incidents. (Also read: 🔧 Virtual machine vs container performance differences — which one optimizes Python workloads?)

  1. S3 Versioning: Retains every object change, allowing point‑in‑time recovery with O(1) access to any prior version.
  2. Bucket ACL & IAM Least‑Privilege: Restricts write actions to a minimal set of trusted roles; explicit Deny statements in bucket policies override any broad Allow permissions.
  3. Amazon Macie: Scans for anomalous object patterns (e.g., sudden spikes in zero‑byte objects) and triggers alerts via SNS.
  4. CloudTrail Insight Rules: Detects spikes in PutObject calls and notifies the security team within seconds.
  5. S3 Object Lock (Governance mode): Makes objects immutable for a defined retention period, blocking overwrite attempts while still permitting authorized administrative overrides.

According to the AWS documentation, combining versioning with Object Lock provides both recoverability and tamper‑resistance, which is the most robust posture against ransomware.

🟩 Final Thoughts

Automating the response to S3 ransomware with Python and Boto3 turns a chaotic incident into a repeatable, low‑latency workflow. By denying writes immediately, revoking compromised credentials, and leveraging versioning for restoration, the window of exposure shrinks from hours to minutes. The preventive controls listed above create a defense‑in‑depth model that makes the same attack vector far more costly for an adversary.

For developers responsible for data pipelines or backup services, integrating the sample script into a CI/CD pipeline or Lambda function ensures that the same logic runs automatically whenever a suspicious event is detected. The result is a measurable reduction in MTTR and a clear audit trail that satisfies compliance requirements.

❓ Frequently Asked Questions

How can I trigger the Python restoration script automatically?

Configure an Amazon EventBridge rule that listens for s3:ObjectCreated:Put events with a zero‑byte payload size, then invoke the script via an AWS Lambda function that has the necessary IAM permissions.

What if my bucket does not have versioning enabled?

Enable versioning as soon as possible; for the current incident, you must rely on external backups or reconstruct the data from upstream systems. Future incidents will be mitigated once versioning is active.

Does Object Lock interfere with normal updates?

Object Lock in Governance mode allows authorized users with the s3:BypassGovernanceRetention permission to overwrite objects, while still protecting against accidental or malicious writes from other principals.

💡 Want to practise this hands-on? DigitalOcean gives new accounts $200 free credit for 60 days — enough to spin up a full Linux/Docker/Kubernetes environment at no cost.

📚 Recommended reading: Best DevOps & cloud books on Amazon — from Linux fundamentals to Kubernetes in production, curated for working engineers.

📚 References & Further Reading

Top comments (0)