如何解决任务处于“运行”状态,这不是执行的有效状态必须清除任务才能运行
我正在尝试使用气流 dag 通过 boto3 将图像上传到 s3 存储桶。但是,每次我得到以下信息时:
任务处于“正在运行”状态,这不是有效的执行状态。必须清除任务才能运行。
我有大约 2 万张图片要上传。在 dag 发生之前,我几乎没有办法做到这一点。
请找到示例代码:
session = boto3.Session()
s3 = session.resource('s3')
bucket_name = 'your-bucket-name'
key = 'your-key-name' # key is the name of file on your bucket
bucket = s3.Bucket(bucket_name)
bucket.upload_fileobj(r.raw,key)```
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。