跨部署微服务平台新年活动

import pika

# 生产者
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')
channel.basic_publish(exchange='', routing_key='hello', body='Hello World!')
print(" [x] Sent 'Hello World!'")
connection.close()

# 消费者
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')

def callback(ch, method, properties, body):
    print(f" [x] Received {body}")

channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)
print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

from saga import Saga

def create_order():
    # 创建订单逻辑
    pass

def reserve_inventory():
    # 预留库存逻辑
    pass

def charge_customer():
    # 扣款逻辑
    pass

saga = Saga()
saga.add_step(create_order)
saga.add_step(reserve_inventory)
saga.add_step(charge_customer)

try:
    saga.execute()
except Exception as e:
    saga.compensate()

from flask import Flask, request
from flask_oauthlib.client import OAuth

app = Flask(__name__)
oauth = OAuth(app)

client = oauth.remote_app(
    'provider_name',
    consumer_key='your_consumer_key',
    consumer_secret='your_consumer_secret',
    request_token_url='https://provider.com/oauth/request_token',
    access_token_url='https://provider.com/oauth/access_token',
    authorize_url='https://provider.com/oauth/authorize'
)

@app.route('/login')
def login():
    return client.authorize(callback='https://yourapp.com/callback')

@app.route('/callback')
def callback():
    response = client.authorized_response()
    if response is None or response.get('access_token') is None:
        return 'Access denied: reason={} error={}'.format(
            request.args['error'],
            request.args['error_description']
        )
    session['access_token'] = response['access_token']
    return 'Logged in!'

if __name__ == '__main__':
    app.run()