您可以从列表列表创建sparkDataframe。举个例子：

data = [[i, '%04d' % (i+31)] for i in range(1,6)]

# [[1, '0032'], [2, '0033'], [3, '0034'], [4, '0035'], [5, '0036']]

df = spark.createDataFrame(data, ['id', 'ordernum'])
df.show()
+---+--------+
| id|ordernum|
+---+--------+
|  1|    0032|
|  2|    0033|
|  3|    0034|
|  4|    0035|
|  5|    0036|
+---+--------+

如果你喜欢Spark范围，你可以使用 format_string :

import pyspark.sql.functions as F
df = spark.range(1, 6).withColumn(
    'ordernum',
    F.format_string('%04d', F.col('id') + 31)
)

df.show()
+---+--------+
| id|ordernum|
+---+--------+
|  1|    0032|
|  2|    0033|
|  3|    0034|
|  4|    0035|
|  5|    0036|
+---+--------+

你可以用 lpad 要创建的函数 ordernum 列自 id + 31 列左填充0以获得一个包含4位数字的字符串编号：

from pyspark.sql import functions as F

output = spark.range(1, 6).withColumn("ordernum", F.lpad(col("id") + 31, 4, '0'))

output.show()

# +---+--------+

# | id|ordernum|

# +---+--------+

# |  1|    0032|

# |  2|    0033|

# |  3|    0034|

# |  4|    0035|

# |  5|    0036|

# +---+--------+