Connect Xata and Azure Blob CSV file in our serverless environment

class HttpSourceXataQuery {
    async init() {
        // TODO: Create team variables. More info at https://yepcode.io/docs/processes/team-variables
        // TODO: Add your http credential with xata information:
        // More info at https://www.npmjs.com/package/axios
        // baseUrl: Your Xata.io base url https://${your-workspace}.${your-zone}.xata.sh/db'
        // HTTP Headers: { "Authorization": "Bearer <your-xata-api-key>" }
        this.httpClient = axios.create({
            baseURL: `https://${yepcode.env.XATA_WORKSPACE}.${yepcode.env.XATA_ZONE}.xata.sh/db`,
            headers: {
                Authorization: `Bearer ${yepcode.env.XATA_API_KEY}`,
            },
        });
    }

    async fetch(publish, done) {
        // TODO: Set your table endpoint parameters
        // You may check API documentation for more details
        // https://xata.io/docs/overview
        const database = "<your-database>";
        const branch = "<your-branch>";
        const table = "<your-table>";
        const pagination = {
            page: {
                size: 15
            }
        };

        await this.httpClient
            .post(`/${database}:${branch}/tables/${table}/query`, pagination)
            .then(({
                data
            }) => {
                for (const row of data.records) {
                    publish(row);
                }
            })
            .catch((error) => {
                console.error(
                    `An error was thrown retrieving data`,
                    error.response.data
                );
                throw error;
            });

        done();
    }

    async close() {}
}

class AzureBlobTargetUploadCsv {
    async init() {
        // More info at https://docs.microsoft.com/en-us/azure/storage/blobs/storage-quickstart-blobs-nodejs
        // TODO: Create team variables. More info at https://yepcode.io/docs/processes/team-variables
        this.azureBlob = BlobServiceClient.fromConnectionString(
            yepcode.env.AZURE_BLOB_CONNECTION_STRING
        );
        // TODO: customize the container name and blob name to upload
        // // More info at https://docs.microsoft.com/en-us/javascript/api/@azure/storage-blob/blobserviceclient?view=azure-node-latest#@azure-storage-blob-blobserviceclient-getcontainerclient
        const containerClient = this.azureBlob.getContainerClient("container-name");
        const blockBlobClient = containerClient.getBlockBlobClient("blob-name");

        // Transforms the items into a csv format
        this.stringifier = csv.stringify({
            delimiter: ",",
        });
        this.upload = blockBlobClient.uploadStream(this.stringifier);
    }

    async consume(item) {
        // TODO: customize the csv row to create from your item content
        const csvRow = [item.value, item.text];
        this.stringifier.write(csvRow);
    }

    async close() {
        try {
            this.stringifier.end();
        } catch (error) {
            console.error(`Error ending stringifier`, error);
        }
        try {
            await this.upload;
        } catch (error) {
            console.error(`Error ending upload`, error);
        }
    }
}