Function Compute:Penanganan

Penanganan stream

Penanganan stream membaca input dari Stream dan mengembalikan Stream.

using System.IO;
using System.Threading.Tasks;
using Aliyun.Serverless.Core;
using Microsoft.Extensions.Logging;

namespace Example
{
    public class Hello
    {
        public async Task<Stream> StreamHandler(Stream input, IFcContext context)
        {
            IFcLogger logger = context.Logger;
            logger.LogInformation("Handle request: {0}", context.RequestId);
            MemoryStream copy = new MemoryStream();
            await input.CopyToAsync(copy);
            copy.Seek(0, SeekOrigin.Begin);
            return copy;
        }

        static void Main(string[] args){}
    }
}

Untuk assembly HelloFcApp, string penanganan untuk contoh ini adalah:

HelloFcApp::Example.Hello::StreamHandler

Elemen utama:

Penanganan POCO

Penanganan POCO menggunakan kelas C# bertipe untuk input dan output. Function Compute secara otomatis melakukan serialisasi dan deserialisasi objek-objek ini menggunakan JSON.Net (Newtonsoft.Json).

using Aliyun.Serverless.Core;
using Microsoft.Extensions.Logging;

namespace Example
{
    public class Hello
    {
        public class Product
        {
            public string Id { get; set; }
            public string Description { get; set; }
        }

        // Opsional: tentukan kelas serializer kustom.
        // Jika dihilangkan, serializer JSON.Net default akan digunakan.
        // [FcSerializer(typeof(MySerialization))]
        public Product PocoHandler(Product product, IFcContext context)
        {
            string Id = product.Id;
            string Description = product.Description;
            context.Logger.LogInformation("Id {0}, Description {1}", Id, Description);
            return product;
        }

        static void Main(string[] args){}
    }
}

Untuk assembly HelloFcApp, string penanganan untuk contoh ini adalah:

HelloFcApp::Example.Hello::PocoHandler

Elemen utama:

Serialisasi

Penanganan POCO menggunakan JSON.Net (Newtonsoft.Json) secara default, yang disediakan oleh Aliyun.Serverless.Core. Ini mencakup sebagian besar kasus penggunaan tanpa konfigurasi tambahan — Function Compute secara otomatis mendeserialisasi event masuk ke jenis input Anda dan menserialisasi nilai kembali ke badan respons.

Kapan menggunakan serializer kustom: jika Anda perlu menangani jenis khusus, konvensi penamaan kustom, atau format non-JSON, implementasikan antarmuka IFcSerializer:

public interface IFcSerializer
{
    T Deserialize<T>(Stream requestStream);
    void Serialize<T>(T response, Stream responseStream);
}

Untuk menggunakan serializer kustom, terapkan atribut [FcSerializer] ke metode penanganan Anda:

[FcSerializer(typeof(MySerialization))]
public Product PocoHandler(Product product, IFcContext context) { ... }

Kode contoh

Contoh berikut mendefinisikan kelas bertipe untuk permintaan dan respons pemicu HTTP, membaca badan permintaan, lalu mengembalikannya.

using System;
using System.Collections.Generic;
using System.Text;
using System.Text.Json;
using Aliyun.Serverless.Core;
using Microsoft.Extensions.Logging;

namespace Example
{
    public class Hello
    {
        public class HTTPTriggerEvent
        {
            public string Version { get; set; }
            public string RawPath { get; set; }
            public string Body { get; set; }
            public bool IsBase64Encoded { get; set; }
            public RequestContext RequestContext { get; set; }
            public Dictionary<string, string> Headers { get; set; }
            public Dictionary<string, string> QueryParameters { get; set; }

            public override string ToString()
            {
                return JsonSerializer.Serialize(this);
            }
        }

        public class RequestContext
        {
            public string AccountId { get; set; }
            public string DomainName { get; set; }
            public string DomainPrefix { get; set; }
            public string RequestId { get; set; }
            public string Time { get; set; }
            public string TimeEpoch { get; set; }
            public Dictionary<string, string> Http { get; set; }
        }

        public class HTTPTriggerResponse
        {
            public int StatusCode { get; set; }
            public Dictionary<string, string> Headers { get; set; }
            public bool IsBase64Encoded { get; set; }
            public string Body { get; set; }
        }

        public HTTPTriggerResponse PocoHandler(HTTPTriggerEvent input, IFcContext context)
        {
            context.Logger.LogInformation("receive event: {0}", input.ToString());
            string requestBody = input.Body;
            if (input.IsBase64Encoded)
            {
                byte[] decodedBytes = Convert.FromBase64String(input.Body);
                requestBody = Encoding.UTF8.GetString(decodedBytes);
            }
            return new HTTPTriggerResponse
            {
                StatusCode = 200,
                IsBase64Encoded = false,
                Body = requestBody
            };
        }
        static void Main(string[] args){}
    }
}

Prasyarat

Sebelum memulai, pastikan Anda telah:

• Membuat fungsi C# menggunakan kode contoh di atas. Untuk informasi selengkapnya, lihat Buat fungsi event dan Konfigurasikan pemicu HTTP.

Panggil fungsi

1. Masuk ke Konsol Function Compute. Di panel navigasi kiri, klik Functions.

2. Di bilah navigasi atas, pilih wilayah. Di halaman Functions, klik fungsi target.

3. Di halaman detail fungsi, klik tab Triggers untuk mendapatkan titik akhir publik pemicu HTTP.

4. Jalankan perintah berikut untuk memanggil fungsi. Ganti https://test-python-ipgrwr****.cn-shanghai.fcapp.run dengan titik akhir Anda.

   curl -i "https://test-python-ipgrwr****.cn-shanghai.fcapp.run" -d 'Hello fc3.0'

   Respons yang diharapkan:

   HTTP/1.1 200 OK
   Content-Disposition: attachment
   Content-Length: 12
   Content-Type: application/json
   X-Fc-Request-Id: 1-64f7449a-127fbe39cd7681596e33ebad
   Date: Tue, 05 Sep 2023 15:09:14 GMT
   
   Hello fc3.0

   Penting

   • Jika Authentication Method diatur ke No Authentication, panggil menggunakan Postman atau curl.

   • Jika Authentication Method diatur ke Signature Authentication atau JWT Authentication, gunakan metode yang sesuai. Untuk informasi selengkapnya, lihat Autentikasi.

Kemungkinan error

Contoh ini dirancang untuk pemanggilan pemicu HTTP atau nama domain kustom. Jika Anda mengklik Test Function di konsol dan memberikan string biasa seperti "Hello, FC!", fungsi akan mengembalikan error deserialisasi karena input tidak sesuai dengan format HTTPTriggerEvent:

{
    "errorMessage": "Unexpected character encountered while parsing value: H. Path '', line 0, position 0.",
    "errorType": "Newtonsoft.Json.JsonReaderException",
    "stackTrace": [
        "   at Newtonsoft.Json.JsonTextReader.ParseValue()",
        "   at Newtonsoft.Json.JsonReader.ReadAndMoveToContent()",
        "   at Newtonsoft.Json.JsonReader.ReadForType(JsonContract contract, Boolean hasConverter)",
        "   at Newtonsoft.Json.Serialization.JsonSerializerInternalReader.Deserialize(JsonReader reader, Type objectType, Boolean checkAdditionalContent)",
        "   at Newtonsoft.Json.JsonSerializer.DeserializeInternal(JsonReader reader, Type objectType)",
        "   at Newtonsoft.Json.JsonSerializer.Deserialize(JsonReader reader, Type objectType)",
        "   at Newtonsoft.Json.JsonSerializer.Deserialize[T](JsonReader reader)",
        "   at Aliyun.Serverless.Core.JsonSerializer.Deserialize[T](Stream requestStream) in /dotnetcore/Libraries/src/Aliyun.Serverless.Core.Impl/JsonSerializer.cs:line 95"
    ]
}