Skip to content
~/sph.sh

AWS CDK Link Kısaltıcı Bölüm 2: Temel Fonksiyonlar & API Geliştirme

Yönlendirme motoru, analytics toplama ve API Gateway konfigürasyonu. Günlük milyonlarca yönlendirmeyi işlemenin gerçek performans optimizasyonları ve debugging stratejileri.

AWS CDK Link Kısaltıcı Bölüm 2: Temel Fonksiyonlar & API Geliştirme

İşte oradaydık, yatırımcılara yaptığımız board sunumunun tam ortasında, yeni pazarlama kampanyası tracking sistemimizi gösteriyorduk. Kısaltılmış linklerden birine tıkladım... ve bekledim. Redirect 3 saniye sürdü. Oda sessizleşti. CEO bana o bakışı attı. O andan sonra redirect performansı bizim için en kritik metrik oldu.

İşte o zaman öğrendim ki link kısaltıcı kurmak sadece kısa kodlar generate etmek değil - ölçekte zarif bir şekilde çalışabilen bir redirect motoru kurmaktır. O biraz garip sunumdan sonra (yine de fonlamayı aldık), redirect sistemimizi proper caching, analytics ve error handling ile yeniden kurduk. CloudFront cache hit oranını optimize etmek ve 404 durumlarını hızlı handle etmek kritik performans faktörleri oldu.

Bölüm 1'de temeli kurduk. Şimdi bu şeyi uçuran gerçek business mantığını kuralım.

Redirect Motoru: Hızın Önemli Olduğu Yer

Redirect handler link kısaltıcının kalbidir. Her milisaniye önemlidir çünkü kullanıcılar anında redirect bekler. İşte production'da test edilmiş implementasyonumuz:

typescript
// lambda/redirect.tsimport { APIGatewayProxyEvent, APIGatewayProxyResult } from 'aws-lambda';import { DynamoDBClient, GetItemCommand } from '@aws-sdk/client-dynamodb';import { unmarshall } from '@aws-sdk/util-dynamodb';
import { NodeHttpHandler } from '@smithy/node-http-handler';
const dynamodb = new DynamoDBClient({  region: process.env.AWS_REGION,  maxAttempts: 3,  requestHandler: new NodeHttpHandler({    connectionTimeout: 1000,    requestTimeout: 2000,  })});
interface AnalyticsEvent {  shortCode: string;  timestamp: number;  userAgent?: string;  referer?: string;  ip?: string;  country?: string;}
export const handler = async (  event: APIGatewayProxyEvent): Promise<APIGatewayProxyResult> => {  const startTime = Date.now();  const shortCode = event.pathParameters?.shortCode;    if (!shortCode) {    return createErrorResponse(400, 'Short code gerekli');  }
  try {    // DynamoDB'den URL'i al    const result = await dynamodb.send(new GetItemCommand({      TableName: process.env.LINKS_TABLE_NAME!,      Key: { shortCode: { S: shortCode } },      ProjectionExpression: 'originalUrl, expiresAt, clickCount',    }));
    if (!result.Item) {      // Analytics için 404'leri takip et      await trackAnalytics({        shortCode,        timestamp: Date.now(),        userAgent: event.headers['User-Agent'],        referer: event.headers['Referer'],        ip: event.requestContext.identity?.sourceIp,      }, 'NOT_FOUND');            return createErrorResponse(404, 'Link bulunamadı');    }
    const item = unmarshall(result.Item);        // Expiration kontrolü    if (item.expiresAt && Date.now() > item.expiresAt) {      return createErrorResponse(410, 'Link süresi dolmuş');    }
    // Analytics'i asenkron olarak takip et (redirect'i bloklaması)    trackAnalytics({      shortCode,      timestamp: Date.now(),      userAgent: event.headers['User-Agent'],      referer: event.headers['Referer'],      ip: event.requestContext.identity?.sourceIp,    }, 'SUCCESS').catch(error => {      console.error('Analytics tracking başarısız:', error);      // Analytics başarısız olursa redirect'i başarısız etme    });
    // Performans metriklerini logla    const responseTime = Date.now() - startTime;    console.log(`Redirect ${responseTime}ms'de işlendi: ${shortCode}`);
    return {      statusCode: 301,      headers: {        Location: item.originalUrl,        'Cache-Control': 'public, max-age=300', // 5 dakika        'X-Response-Time': `${responseTime}ms`,      },      body: '',    };
  } catch (error) {    console.error('Redirect hatası:', error);        return createErrorResponse(500, 'Internal server hatası');  }};
function createErrorResponse(statusCode: number, message: string): APIGatewayProxyResult {  return {    statusCode,    headers: { 'Content-Type': 'text/html', 'Cache-Control': 'no-cache' },    body: `<!DOCTYPE html><html><head><title>Link Error</title></head><body><h1>${statusCode === 404 ? 'Link Bulunamadı' : 'Hata'}</h1><p>${message}</p></body></html>`,  };}

Analytics: Business Intelligence Katmanı

Analytics link kısaltıcımızı sadece kolaylıktan öte değerli kıldı. İşte tık verilerini nasıl topluyoruz ve saklıyoruz:

typescript
// lambda/analytics.tsimport { DynamoDBClient, PutItemCommand, UpdateItemCommand } from '@aws-sdk/client-dynamodb';import { marshall } from '@aws-sdk/util-dynamodb';import crypto from 'crypto';
const dynamodb = new DynamoDBClient({ region: process.env.AWS_REGION });
function hashIP(ip: string): string {  return crypto.createHash('sha256').update(ip + process.env.IP_SALT).digest('hex').substring(0, 16);}
async function getCountryFromIP(ip?: string): Promise<string> {  if (!ip) return 'unknown';  try { return 'US'; } catch { return 'unknown'; }}
async function trackAnalytics(  event: AnalyticsEvent,   eventType: 'SUCCESS' | 'NOT_FOUND' = 'SUCCESS'): Promise<void> {  const timestamp = Date.now();  const analyticsItem = {    shortCode: event.shortCode,    timestamp,    eventType,    userAgent: event.userAgent || 'unknown',    referer: event.referer || 'direct',    ip: hashIP(event.ip || ''), // Privacy-first yaklaşım    country: await getCountryFromIP(event.ip),    // Efficient query'ler için saatlik partition    hourPartition: `${event.shortCode}#${Math.floor(timestamp / (1000 * 60 * 60))}`,  };
  // Analytics tablosunda sakla  await dynamodb.send(new PutItemCommand({    TableName: process.env.ANALYTICS_TABLE_NAME!,    Item: marshall(analyticsItem),  }));
  // Ana kayıttaki tık sayısını güncelle (sadece başarılı tıklar için)  if (eventType === 'SUCCESS') {    await dynamodb.send(new UpdateItemCommand({      TableName: process.env.LINKS_TABLE_NAME!,      Key: { shortCode: { S: event.shortCode } },      UpdateExpression: 'ADD clickCount :inc SET lastClickAt = :timestamp',      ExpressionAttributeValues: {        ':inc': { N: '1' },        ':timestamp': { N: timestamp.toString() },      },    }));  }}

API Gateway: Ön Kapı

İşte milyonlarca isteği kırmadan handle eden CDK konfigürasyonumuz:

typescript
// lib/api-stack.tsimport * as cdk from 'aws-cdk-lib';import * as apigateway from 'aws-cdk-lib/aws-apigateway';import * as lambda from 'aws-cdk-lib/aws-lambda';import * as logs from 'aws-cdk-lib/aws-logs';
export class ApiStack extends cdk.Stack {  constructor(scope: Construct, id: string, props: ApiStackProps) {    super(scope, id, props);
    // Custom domain ile API Gateway    const api = new apigateway.RestApi(this, 'LinkShortenerApi', {      restApiName: 'Link Shortener Servisi',      description: 'Production link kısaltıcı API',            // Performans optimizasyonları      minimumCompressionSize: 1024,      binaryMediaTypes: ['*/*'],            // CORS konfigürasyonu      defaultCorsPreflightOptions: {        allowOrigins: apigateway.Cors.ALL_ORIGINS,        allowMethods: ['GET', 'POST', 'OPTIONS'],        allowHeaders: [          'Content-Type',          'X-Amz-Date',          'Authorization',          'X-Api-Key',          'X-Amz-Security-Token',        ],        maxAge: cdk.Duration.hours(1),      },
      // Request validation        requestValidator: new apigateway.RequestValidator(this, 'RequestValidator', {        restApi: api,        validateRequestBody: true,        validateRequestParameters: true,      }),    });
    // Redirect route ekle: GET /{shortCode}    const redirectIntegration = new apigateway.LambdaIntegration(props.redirectHandler, {      proxy: true,      allowTestInvoke: false, // Performans için test invoke'u devre dışı bırak    });
    api.root.addResource('{shortCode}').addMethod('GET', redirectIntegration, {      requestParameters: { 'method.request.path.shortCode': true },    });
    // Link oluşturma API: POST /api/shorten    const apiResource = api.root.addResource('api');    const shortenResource = apiResource.addResource('shorten');
    const createIntegration = new apigateway.LambdaIntegration(props.createHandler, {      proxy: true,    });
    shortenResource.addMethod('POST', createIntegration, {      requestModels: {        'application/json': this.createRequestModel(api),      },      requestValidator: api.requestValidator,    });
    // Analytics API: GET /api/analytics/{shortCode}    const analyticsResource = apiResource.addResource('analytics');    const analyticsCodeResource = analyticsResource.addResource('{shortCode}');    analyticsCodeResource.addMethod('GET', new apigateway.LambdaIntegration(props.analyticsHandler));
    // CloudWatch detaylı metrikleri etkinleştir    api.deploymentStage.addMethodStage('*/*', {      metricsEnabled: true,      loggingLevel: apigateway.MethodLoggingLevel.INFO,      dataTraceEnabled: false,  // Prod'da performans için kapalı      throttlingBurstLimit: 2000,      throttlingRateLimit: 1000,    });  }
  private createRequestModel(api: apigateway.RestApi): apigateway.Model {    return new apigateway.Model(this, 'ShortenRequestModel', {      restApi: api,      contentType: 'application/json',      schema: {        type: apigateway.JsonSchemaType.OBJECT,        properties: {          url: {            type: apigateway.JsonSchemaType.STRING,            pattern: '^https?://.+',            minLength: 10,            maxLength: 2048,          },          customCode: {            type: apigateway.JsonSchemaType.STRING,            pattern: '^[a-zA-Z0-9-_]{3,20}$',          },          expiresIn: {            type: apigateway.JsonSchemaType.NUMBER,            minimum: 3600,   // 1 saat minimum            maximum: 31536000,  // 1 yıl maksimum          },        },        required: ['url'],        additionalProperties: false,      },    });  }}

Production'dan Performans Dersleri

50M+ redirect handle ettikten sonra, gerçekten önemli olan performans pattern'leri:

1. Connection Pooling İstek Başına 50ms Kurtarır

Yukarıdaki DynamoDB client konfigürasyonu connection pooling içerir. Onsuz, her Lambda cold start yeni connection'lar yaratır, 50-100ms latency ekler. Doğru pooling ile:

  • Cold start redirect: ~200ms
  • Warm redirect: ~15ms
  • Connection reuse rate: %85

2. Asenkron Analytics Kullanıcıları Bloklamaz

Başlangıçta analytics'i senkron olarak takip ediyorduk. Kötü fikir. Kullanıcılar analytics başarısız olursa umursamazlar, ama redirect'ler yavaşsa kesinlikle umursarlar. Fire-and-forget analytics toplama P95 yanıt süresini 300ms'den 45ms'e düşürdü.

3. DynamoDB Projection'ları Önemli

GetItem çağrılarımızda ProjectionExpression kullanmak response boyutlarını %60 azalttı. Redirect için yalnızca originalUrl, expiresAt, clickCount çekiyoruz. Analytics sorguları ayrı bir GSI kullanıyor.

Production Hata Ayıklama

CloudWatch Insights Sorguları

sql
fields @timestamp, @message| filter @message like /Redirect processed/| stats avg(responseTime) by bin(5m)| sort @timestamp desc
sql
fields @timestamp, @message| filter @message like /error/| stats count() by shortCode| sort count desc| limit 20

Lambda Performans İzleme

typescript
// Handler'a ekleconst COLD_START = !global.isWarm;global.isWarm = true;
console.log(JSON.stringify({  coldStart: COLD_START,  responseTime: Date.now() - startTime,  shortCode,  success: statusCode < 400,}));

Redirect Engine'ınızı Test Etme

typescript
// tests/redirect.test.tsimport { handler } from '../lambda/redirect';
describe('Redirect Handler', () => {  beforeEach(() => {    process.env.LINKS_TABLE_NAME = 'test-links';    process.env.ANALYTICS_TABLE_NAME = 'test-analytics';  });
  test('should redirect to original URL', async () => {    const result = await handler(createAPIGatewayEvent('/abc123'));    expect(result.statusCode).toBe(301);    expect(result.headers.Location).toBe('https://example.com');    expect(result.headers['Cache-Control']).toBe('public, max-age=300');  });
  test('should handle expired links gracefully', async () => {    const result = await handler(createAPIGatewayEvent('/expired'));    expect(result.statusCode).toBe(410);    expect(result.body).toContain('expired');  });});
function createAPIGatewayEvent(shortCode: string) {  return { pathParameters: { shortCode }, headers: {}, requestContext: { identity: {} } };}

Jest ile handler testleri: LINKS_TABLE_NAME ve ANALYTICS_TABLE_NAME env'leri. 301 redirect, 410 expired, Cache-Control header'larını doğrulayın.

Sırada Ne Var

Bölüm 3'te servisinizi spam vektörü olmaktan koruyan güvenlik özelliklerini ekleyeceğiz: rate limiting, click fraud tespiti ve custom domain ile SSL sertifikaları.

Sağlam bir redirect motoru kurduk, ancak production bize güvenliğin opsiyonel olmadığını öğretti – hobby projesini business-critical servisten ayıran da bu. Spam saldırıları sırasında servisi ayakta tutan anti-abuse önlemlerini bir sonraki bölümde implement edeceğiz.

AWS CDK Link Kısaltıcı: Sıfırdan Production'a

AWS CDK, Node.js Lambda ve DynamoDB ile production-grade bir link kısaltma servisi kurulumu hakkında 5 bölümlük kapsamlı seri. Gerçek production hikayeleri, performans optimizasyonu ve maliyet yönetimi dahil.

İlerleme2/5 yazı tamamlandı
Önceki
Proje Kurulumu & Temel Altyapı
Sonraki
Gelişmiş Özellikler & Güvenlik
Seriyi görüntüle →
aws-cdk
lambda
api-gateway
analytics
nodejs
typescript
redirect
performance
debugging

İlgili Yazılar