小编con*_*nor的帖子

我正在努力设置带有条带的定期付款.我正在使用react-stripe-elements来收集卡片信息,看起来有两种方法可以保存卡片以供日后使用:

• this.props.stripe.createToken()
• this.props.stripe.createSource()

然后在后端创建一个客户:

• stripe.customers.create({ source: tokenId })
• stripe.customers.create({ source: sourceId })

条带仪表板中的结果:

• tokenId

  • tokenId卡

• 的SourceID

  • sourceId源码

• sourceId卡

我的问题是这两种模式之间有什么区别？我应该使用一个而不是另一个吗？我注意到在tokenId模式中,卡表示cvc/zip检查已通过,而卡片未在sourceId模式中说明.但sourceId模式也明确表示该卡是收费和可重复使用的,这是否意味着使用tokenId模式保存的卡不可重复使用？sourceId卡中的日志/事件更有用吗？两种模式的返回对象结构也不同.

任何帮助将非常感谢,提前感谢!

早上好.

我正在尝试设置DAG

1. 观察/感知文件以命中网络文件夹
2. 处理文件
3. 归档文件

使用在线教程和stackoverflow我已经能够提出以下DAG和运算符成功实现目标,但是我希望DAG重新安排或在完成时重新运行,以便开始观察/感知另一个文件.

我试图设置一个变量max_active_runs:1,然后schedule_interval: timedelta(seconds=5)这个是重新安排DAG,但开始排队任务并锁定文件.

欢迎任何关于如何在archive_task之后重新运行DAG的想法？

谢谢

DAG代码

from airflow import DAG
from airflow.operators import PythonOperator, OmegaFileSensor, ArchiveFileOperator
from datetime import datetime, timedelta
from airflow.models import Variable

default_args = {
    'owner': 'glsam',
    'depends_on_past': False,
    'start_date': datetime.now(),
    'provide_context': True,
    'retries': 100,
    'retry_delay': timedelta(seconds=30),
    'max_active_runs': 1,
    'schedule_interval': timedelta(seconds=5),
}

dag = DAG('test_sensing_for_a_file', default_args=default_args)

filepath = Variable.get("soucePath_Test")
filepattern = Variable.get("filePattern_Test")
archivepath = Variable.get("archivePath_Test")

sensor_task = OmegaFileSensor(
    task_id='file_sensor_task',
    filepath=filepath,
    filepattern=filepattern,
    poke_interval=3,
    dag=dag)


def process_file(**context):
    file_to_process = context['task_instance'].xcom_pull( …