文件存储

1
// read from S3 bucket
2
const data = await Deno.readFile('/s3/my-bucket/results.csv')
3
4
// make a directory
5
await Deno.mkdir('/s3/my-bucket/sub-dir')
6
7
// write to S3 bucket
8
await Deno.writeTextFile('/s3/my-bucket/demo.txt', 'hello world')

1
Deno.serve(async (req) => {
2
  if (req.headers.get('content-type') !== 'application/zip') {
3
    return new Response('file must be a zip file', {
4
      status: 400,
5
    })
6
  }
7
8
  const uploadId = crypto.randomUUID()
9
  await Deno.writeFile('/tmp/' + uploadId, req.body)
10
11
  // E.g. extract and process the zip file
12
  const zipFile = await Deno.readFile('/tmp/' + uploadId)
13
  // You could use a zip library to extract contents
14
  const extracted = await extractZip(zipFile)
15
16
  // Or process the file directly
17
  console.log(`Processing zip file: ${uploadId}, size: ${zipFile.length} bytes`)
18
})

1
import { BlobWriter, ZipReader } from 'https://deno.land/x/zipjs/index.js'
2
import { createClient } from 'jsr:@supabase/supabase-js@2'
3
4
const SUPABASE_SECRET_KEYS = JSON.parse(Deno.env.get('SUPABASE_SECRET_KEYS')!)
5
// If you want to use a different api key, change 'default' to your preferred key name
6
const supabase = createClient(Deno.env.get('SUPABASE_URL')!, SUPABASE_SECRET_KEYS['default'])
7
8
async function processZipFile(uploadId: string, filepath: string) {
9
  const file = await Deno.open(filepath, { read: true })
10
  const zipReader = new ZipReader(file.readable)
11
  const entries = await zipReader.getEntries()
12
13
  await supabase.storage.createBucket(uploadId, { public: false })
14
15
  await Promise.all(
16
    entries.map(async (entry) => {
17
      if (entry.directory) return
18
19
      // Read file entry from temp storage
20
      const blobWriter = new BlobWriter()
21
      const blob = await entry.getData(blobWriter)
22
23
      // Upload to permanent storage
24
      await supabase.storage.from(uploadId).upload(entry.filename, blob)
25
26
      console.log('uploaded', entry.filename)
27
    })
28
  )
29
30
  await zipReader.close()
31
}
32
33
Deno.serve(async (req) => {
34
  const uploadId = crypto.randomUUID()
35
  const filepath = `/tmp/${uploadId}.zip`
36
37
  // Write zip to ephemeral storage
38
  await Deno.writeFile(filepath, req.body)
39
40
  // Process in background to avoid memory limits
41
  EdgeRuntime.waitUntil(processZipFile(uploadId, filepath))
42
43
  return new Response(JSON.stringify({ uploadId }), {
44
    headers: { 'Content-Type': 'application/json' },
45
  })
46
})

1
Deno.serve(async (req) => {
2
  // Save uploaded image to temp storage
3
  const imagePath = `/tmp/input-${crypto.randomUUID()}.jpg`
4
  await Deno.writeFile(imagePath, req.body)
5
6
  // Process image with magick-wasm
7
  const processedPath = `/tmp/output-${crypto.randomUUID()}.jpg`
8
  // ... image manipulation logic
9
10
  // Read processed image and return
11
  const processedImage = await Deno.readFile(processedPath)
12
  return new Response(processedImage, {
13
    headers: { 'Content-Type': 'image/jpeg' },
14
  })
15
})

1
Deno.statSync('...') // ✅
2
3
setTimeout(() => {
4
  Deno.statSync('...') // 💣 ERROR! Deno.statSync is blocklisted on the current context
5
})
6
7
Deno.serve(() => {
8
  Deno.statSync('...') // 💣 ERROR! Deno.statSync is blocklisted on the current context
9
})