Filter by prefix of bucket object name
This commit is contained in:
parent
6f43467cd7
commit
71fbe25111
|
@ -253,6 +253,10 @@ async fn queue(message_batch: MessageBatch<R2Message>, env: Env, _ctx: Context)
|
||||||
let messages = message_batch.messages()?;
|
let messages = message_batch.messages()?;
|
||||||
for message in messages {
|
for message in messages {
|
||||||
let fname = message.body.object.key;
|
let fname = message.body.object.key;
|
||||||
|
let dir: Vec<&str> = fname.split("/").collect();
|
||||||
|
if dir[0] != "posts" {
|
||||||
|
continue
|
||||||
|
}
|
||||||
console_log!("got {} to render and index", &fname);
|
console_log!("got {} to render and index", &fname);
|
||||||
let file = bucket.get(&fname).execute().await?;
|
let file = bucket.get(&fname).execute().await?;
|
||||||
if file.is_none() {
|
if file.is_none() {
|
||||||
|
|
Loading…
Reference in a new issue