Upstash Skills

# Upstash Redis SDK: Publishing Messages to a Stream

## Overview
Upstash Redis Streams enable real-time messaging between microservices. Below is a Python example using the `upstash_redis` SDK to publish a message to a stream.

## Prerequisites
- Python 3.7+
- Upstash Redis database URL and token (from [Upstash Console](https://console.upstash.com))

## Code Example
```python
from upstash_redis import Redis

# Initialize Redis client
redis = Redis(
    url="YOUR_UPSTASH_REDIS_URL",
    token="YOUR_UPSTASH_REDIS_TOKEN"
)

# Publish a message to a stream
stream_name = "user_activity"
message = {
    "user_id": "12345",
    "action": "login",
    "timestamp": "2023-11-15T12:00:00Z"
}

response = redis.xadd(stream_name, message)
print(f"Message published. ID: {response}")
```

## Best Practices
- **Error Handling**: Always wrap Redis operations in try-except blocks to handle network issues.
- **Stream Naming**: Use consistent naming conventions (e.g., `user_activity`, `order_updates`).
- **TTL**: Set TTL for streams if messages are temporary.

## Common Pitfalls
- **Token Exposure**: Never hardcode tokens in your application. Use environment variables.
- **Connection Limits**: Upstash has rate limits. Batch operations where possible.

## Next Steps
- [Upstash Streams Documentation](https://docs.upstash.com/redis/streams)
- [Python SDK Reference](https://github.com/upstash/upstash-redis-py)