小编Yog*_*ann的帖子

Apache Spark读取S3:无法pickle thread.lock对象

所以我希望我的Spark应用程序能够从亚马逊的S3中读取一些文本.我写了以下简单的脚本:

import boto3
s3_client = boto3.client('s3')
text_keys = ["key1.txt", "key2.txt"]
data = sc.parallelize(text_keys).flatMap(lambda key: s3_client.get_object(Bucket="my_bucket", Key=key)['Body'].read().decode('utf-8'))
Run Code Online (Sandbox Code Playgroud)

当我这样做时,data.collect我收到以下错误:

TypeError: can't pickle thread.lock objects
Run Code Online (Sandbox Code Playgroud)

我似乎没有在网上找到任何帮助.也许有人设法解决了上述问题?

python multithreading amazon-s3 apache-spark pyspark

6
推荐指数
1
解决办法
2791
查看次数

Android Firebase 身份验证未使用 11.8.0 以上的 SDK 接收短信

我正在实现使用 Firebase 来验证我的用户身份的 Android 应用程序,

我的问题是,在更改 Gradle 依赖项后:

implementation 'com.google.firebase:firebase-auth:11.8.0'
Run Code Online (Sandbox Code Playgroud)

对于任何更高的SDK 版本,我的代码停止发送 SMS 身份验证消息。

我的代码:

public class AuthenticationActivity extends AppCompatActivity {
    private PhoneAuthProvider.OnVerificationStateChangedCallbacks mCallbacks;
    private EditText phoneNum;
    private PinView verifyCodeET;
    private String mVerificationId;
    private FirebaseAuth mAuth;
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_authentication);
        mAuth = FirebaseAuth.getInstance();
        Button sendCodeButton = findViewById(R.id.submit1);
        Button verifyCodeButton = findViewById(R.id.submit2);
        phoneNum = findViewById(R.id.phonenumber);
        verifyCodeET = findViewById(R.id.pinView);
        sendCodeButton.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View view) {
                String phoneNumber = phoneNum.getText().toString();
                PhoneAuthProvider.getInstance().verifyPhoneNumber(
                        phoneNumber, // Phone …
Run Code Online (Sandbox Code Playgroud)

android firebase firebase-authentication

5
推荐指数
1
解决办法
4563
查看次数